Struct MemoryTransport 

pub struct MemoryTransport { /* private fields */ }

In-memory transport for testing sync sessions.

Uses mpsc channels for bidirectional communication. Thread-safe (Send + Sync) so each side can be shared with a scoped thread via &self.

Create a connected pair with MemoryTransport::pair().

Implementations

impl MemoryTransport

pub fn pair() -> (Self, Self)

Create a connected pair of transports.

Messages sent on one side are received by the other.

Trait Implementations

impl SyncTransport for MemoryTransport

fn send(&self, msg: &SyncMessage) -> Result<(), SyncError>

Send a message to the remote peer.

fn recv(&self) -> Result<SyncMessage, SyncError>

Receive the next message from the remote peer.

fn close(&self) -> Result<(), SyncError>

Close the transport connection.