Trait CommandChannel 

pub trait CommandChannel: Send + Sync {
    // Required methods
    fn id(&self) -> &str;
    fn start(&self) -> BoxFuture<'_, Result<(), ChannelError>>;
    fn close(&self) -> BoxFuture<'_, ()>;
    fn send(&self, msg: Message) -> Result<(), ChannelError>;
    fn recv(&self) -> BoxFuture<'_, Option<Message>>;
}

Transport carrying Messages between two command registries.

Every method takes &self so the channel can be shared across tasks as an Arc<dyn CommandChannel>. Implementations provide their own interior synchronization. The registry drives recv from a single task, so implementations may assume a single concurrent recv caller.

The async methods return BoxFuture rather than impl Future so dyn CommandChannel is object-safe. This is the same shape #[async_trait] produces internally, written out by hand to avoid the dependency.

Required Methods

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.

Implementors

impl CommandChannel for InMemoryChannel