Struct MemoryChannel 

pub struct MemoryChannel {
    pub sender: Sender<Vec<CanonicalMessage>>,
    pub receiver: Receiver<Vec<CanonicalMessage>>,
}

A shareable, thread-safe, in-memory channel for testing.

This struct holds the sender and receiver for an in-memory queue. It can be cloned and shared between your test code and the bridge’s endpoints. It transports batches of messages.

Fields

sender: Sender<Vec<CanonicalMessage>>

receiver: Receiver<Vec<CanonicalMessage>>

Implementations

impl MemoryChannel

pub fn new(capacity: usize) -> Self

Creates a new batch channel with a specified capacity.

pub async fn send_message(&self, message: CanonicalMessage) -> Result<()>

Helper function for tests to easily send a message to the channel.

pub async fn fill_messages(&self, messages: Vec<CanonicalMessage>) -> Result<()>

Helper function for tests to easily fill in messages.

pub fn close(&self)

Closes the sender part of the channel.

pub fn drain_messages(&self) -> Vec<CanonicalMessage>

Helper function for tests to drain all messages from the channel.

pub fn len(&self) -> usize

Returns the number of bulk messages in the channel.

pub fn is_empty(&self) -> bool

Returns the number of messages currently in the channel.

Trait Implementations

impl Clone for MemoryChannel

fn clone(&self) -> MemoryChannel

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MemoryChannel

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

Formats the value using the given formatter.