Struct ChannelTransport 

pub struct ChannelTransport<M> { /* private fields */ }

An in-memory NetworkTransport pair over std::sync::mpsc channels.

The engine’s built-in mock: the two ends of one link connection with zero I/O, used for local play and tests. Dropping one end makes the other report TransportError::Disconnected exactly like a closed socket.

Implementations

impl<M> ChannelTransport<M>

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

Create a connected pair — the two ends of one link connection.

Trait Implementations

impl<M> NetworkTransport<M> for ChannelTransport<M>

fn send(&mut self, msg: M) -> Result<(), TransportError>

Send one message to the peer.

fn recv(&mut self) -> Result<M, TransportError>

Block until a message arrives or the connection fails.

fn try_recv(&mut self) -> Result<Option<M>, TransportError>

Non-blocking receive: Ok(None) when nothing is pending, Err(Disconnected) once the peer is gone.