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>,
}

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>

Implementations

impl TestCommunicationBackend

pub fn new() -> Self

Create a new test communication backend.

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 = ()

type Receiver = TestCommunicationBackendReceiver

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 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.