Struct InMemoryTransport 

pub struct InMemoryTransport { /* private fields */ }

In-memory transport for testing.

Messages are delivered in FIFO order per sender-receiver pair.

Implementations

impl InMemoryTransport

pub fn new() -> Self

Create a new in-memory transport.

pub fn with_shared_queues( queues: Arc<Mutex<BTreeMap<(RoleName, RoleName), VecDeque<ProtocolEnvelope>>>>, ) -> Self

Create a new transport with shared queues.

Multiple transports sharing queues can communicate with each other.

pub fn set_role(&mut self, role: RoleName)

Set the role for this transport.

pub fn role(&self) -> Option<&RoleName>

Get the current role.

pub fn all_messages(&self) -> Vec<ProtocolEnvelope>

Get all messages in transit (for debugging).

pub fn clear(&mut self)

Clear all message queues.

pub fn pending_count(&self) -> usize

Get the number of pending messages.

Trait Implementations

impl AsyncSimulatedTransport for InMemoryTransport

fn send<'life0, 'life1, 'async_trait>( &'life0 mut self, to: &'life1 RoleName, envelope: ProtocolEnvelope, ) -> Pin<Box<dyn Future<Output = TransportResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a message to a destination.

fn recv<'life0, 'life1, 'async_trait>( &'life0 mut self, from: &'life1 RoleName, ) -> Pin<Box<dyn Future<Output = TransportResult<ProtocolEnvelope>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Receive a message from a source, waiting if necessary.

fn try_recv( &mut self, from: &RoleName, ) -> TransportResult<Option<ProtocolEnvelope>>

Try to receive a message without blocking.

fn has_message(&self, from: &RoleName) -> bool

Check if a message is available from a source.

impl Clone for InMemoryTransport

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryTransport

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

Formats the value using the given formatter.

impl Default for InMemoryTransport

fn default() -> InMemoryTransport

Returns the “default value” for a type.

impl SimulatedTransport for InMemoryTransport

fn send( &mut self, to: &RoleName, envelope: ProtocolEnvelope, ) -> TransportResult<()>

Send a message to a destination.

fn recv(&mut self, from: &RoleName) -> TransportResult<ProtocolEnvelope>

Receive a message from a source.

fn peek(&self, from: &RoleName) -> bool

Check if a message is available from a source without consuming it.

fn pending_messages(&self) -> Vec<&ProtocolEnvelope>

Get all pending messages (for debugging/inspection).