Struct TokioMessageBus 

pub struct TokioMessageBus { /* private fields */ }

Concrete MessageBusPort backed by tokio::sync::mpsc channels.

Each TokioMessageBus instance holds one direction of communication. Use MessageBusHandle to create a matched pair.

Trait Implementations

impl Debug for TokioMessageBus

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl MessageBusPort for TokioMessageBus

fn send<'life0, 'async_trait>( &'life0 self, msg: OutboundMessage, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send an outbound message to the bus.

fn recv<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<InboundMessage, AgentError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Receive the next inbound message (blocks until available).