Struct InMemoryEndpoint 

pub struct InMemoryEndpoint { /* private fields */ }

One end of an in-memory replication channel.

Implements Channel identically to crate::net::TcpChannel and crate::net::TlsTcpChannel. Internally backed by LocalChannel queues and a noxu_sync::Mutex.

Endpoints are constructed via InMemoryTransport::new_pair or InMemoryTransport::new_group. Direct construction is intentionally not exposed — pairing two endpoints requires the cross-connected queues set up by the transport factory.

Implementations

impl InMemoryEndpoint

pub fn channel_handle(&self) -> Arc<dyn Channel>

Return a cheap shareable handle to this endpoint’s underlying channel. Useful when the protocol layer wants Arc<dyn Channel> (e.g., when spawning a reader thread that outlives the borrow of the group).

Trait Implementations

impl Channel for InMemoryEndpoint

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.