Struct LocalChannel 

pub struct LocalChannel { /* private fields */ }

In-memory channel for testing. One end of a LocalChannelPair.

Messages sent on this channel appear in the receive queue of the paired channel, and vice versa. This provides a simple loopback mechanism for unit testing protocol and data channel code without real sockets.

Trait Implementations

impl Channel for LocalChannel

fn send(&self, data: &[u8]) -> Result<()>

Send a message (bytes) through the channel.

fn receive(&self, timeout: Duration) -> Result<Option<Vec<u8>>>

Receive a message, blocking until data is available or the timeout expires. Returns Ok(None) on timeout with no data.

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

Close the channel. After closing, further sends will fail and receives will return None.

fn is_open(&self) -> bool

Check if the channel is still open.