Struct MockDataChannel 

pub struct MockDataChannel { /* private fields */ }

Mock data channel using mpsc channels

Implementations

impl MockDataChannel

pub fn pair(id_a: u64, id_b: u64) -> (Self, Self)

Create a connected pair of mock channels

pub fn pair_with_latency(id_a: u64, id_b: u64, latency_ms: u64) -> (Self, Self)

Create a connected pair with simulated latency

pub fn pair_with_latency_mode( id_a: u64, id_b: u64, latency_ms: u64, latency_mode: MockLatencyMode, ) -> (Self, Self)

Create a connected pair with explicit latency mode.

pub fn peer_id(&self) -> u64

Get peer ID

Trait Implementations

impl PeerLink for MockDataChannel

fn send<'life0, 'async_trait>( &'life0 self, data: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

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

Send data to the peer.

fn recv<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Option<Vec<u8>>> + Send + 'async_trait>>

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

Receive data from the peer.

fn try_recv(&self) -> Option<Vec<u8>>

Try to receive data without blocking. Returns None when no message is currently available.

fn is_open(&self) -> bool

Check if the link is open.

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Close the link.