Struct InMemoryChannel 

pub struct InMemoryChannel { /* private fields */ }

In-process CommandChannel backed by unbounded futures MPSC queues. Useful for tests and for wiring multiple registries running inside a single process (e.g. across async tasks or worker threads).

Implementations

impl InMemoryChannel

pub fn pair( id_a: impl Into<String>, id_b: impl Into<String>, ) -> (Arc<Self>, Arc<Self>)

Returns two channels wired to each other. A message sent on one arrives on the other’s recv.

Each half carries a label, since the registry uses it as the routing key. The two halves typically use each other’s labels: the parent calls the child channel "child" and vice versa.

Trait Implementations

impl CommandChannel for InMemoryChannel

fn id(&self) -> &str

Stable identifier used by the registry to key routing tables.

fn start(&self) -> BoxFuture<'_, Result<(), ChannelError>>

Performs any connection/handshake setup. Called once by the registry before the first recv.

fn close(&self) -> BoxFuture<'_, ()>

Releases any resources and signals the peer that the channel is going away. After close, send must return Err(Closed) and recv must return None.

fn send(&self, msg: Message) -> Result<(), ChannelError>

Fire-and-forget send. Returns immediately without waiting for the peer to receive the message.

fn recv(&self) -> BoxFuture<'_, Option<Message>>

Awaits the next incoming message. Returns None when the channel has been closed by either side.