Struct TestCommunicationBackend 

pub struct TestCommunicationBackend {
    outgoing_tx: Sender<OutgoingMessage>,
    outgoing_rx: Receiver<OutgoingMessage>,
    outgoing: Arc<RwLock<Vec<OutgoingMessage>>>,
    incoming_tx: Sender<IncomingMessage>,
    incoming_rx: Receiver<IncomingMessage>,
    resolution: Arc<RwLock<Option<BroadcastResolution>>>,
}

A test implementation of the CommunicationBackend trait. Provides methods to inject incoming messages and inspect outgoing messages.

Fields

outgoing_tx: Sender<OutgoingMessage>

outgoing_rx: Receiver<OutgoingMessage>

outgoing: Arc<RwLock<Vec<OutgoingMessage>>>

incoming_tx: Sender<IncomingMessage>

incoming_rx: Receiver<IncomingMessage>

resolution: Arc<RwLock<Option<BroadcastResolution>>>

Implementations

impl TestCommunicationBackend

pub fn new() -> Self

Create a new test communication backend.

pub async fn set_resolution(&self, resolution: BroadcastResolution)

Make resolve return resolution for every group. Until this is called, every group resolves to BroadcastResolution::Unsupported, like the trait’s default.

pub fn push_incoming(&self, message: IncomingMessage)

Inject a message as if it were received from a remote endpoint.

pub async fn outgoing(&self) -> Vec<OutgoingMessage>

Get a copy of all the outgoing messages that have been sent.

pub async fn drain_outgoing(&self) -> Vec<OutgoingMessage>

Drain all outgoing messages, returning them and clearing the internal buffer.

Trait Implementations

impl Clone for TestCommunicationBackend

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl CommunicationBackend for TestCommunicationBackend

type SendError = ()

Error returned by send, classified via IpcErrorKind.

type Receiver = TestCommunicationBackendReceiver

Receiver type returned by subscribe.

async fn send(&self, message: OutgoingMessage) -> Result<(), Self::SendError>

Send a message to the destination specified in the message. This function may be called from any thread at any time.

async fn resolve(&self, _group: &BroadcastGroup) -> BroadcastResolution

Resolve a BroadcastGroup into the endpoints that are currently its members. Called by IpcClient::broadcast, which rejects any resolved endpoint that falls outside the group.

async fn subscribe(&self) -> Self::Receiver

Subscribe to receive messages. This function will return a receiver that can be used to receive messages asynchronously.

impl Debug for TestCommunicationBackend

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for TestCommunicationBackend

fn default() -> Self

Returns the “default value” for a type.