Struct MessageBus 

pub struct MessageBus { /* private fields */ }

Implementations

impl MessageBus

pub fn new() -> Self

Create a new message bus with the default channel capacity (1024).

pub fn with_capacity(capacity: usize) -> Self

Create a new message bus with a custom channel capacity.

Higher capacity allows more burst buffering at the cost of memory. Lower capacity provides tighter backpressure.

pub fn publish_inbound(&self, msg: InboundMessage) -> Result<(), ClawftError>

Publish an inbound message (from a channel adapter) to the bus.

Uses try_send to avoid requiring the caller to be async. Returns an error if the channel is closed or the buffer is full.

pub async fn publish_inbound_async( &self, msg: InboundMessage, ) -> Result<(), ClawftError>

Publish an inbound message, waiting asynchronously if the buffer is full.

Prefer this over publish_inbound in async contexts to avoid dropping messages under backpressure.

pub async fn consume_inbound(&self) -> Option<InboundMessage>

Consume the next inbound message from the bus.

Returns None if the channel is closed and all buffered messages have been consumed.

pub fn dispatch_outbound(&self, msg: OutboundMessage) -> Result<(), ClawftError>

Dispatch an outbound message (from the agent pipeline) to the bus.

Uses try_send to avoid requiring the caller to be async. Returns an error if the channel is closed or the buffer is full.

pub async fn dispatch_outbound_async( &self, msg: OutboundMessage, ) -> Result<(), ClawftError>

Dispatch an outbound message, waiting asynchronously if the buffer is full.

pub async fn consume_outbound(&self) -> Option<OutboundMessage>

Consume the next outbound message from the bus.

Returns None if the channel is closed and all buffered messages have been consumed.

pub fn inbound_sender(&self) -> Sender<InboundMessage>

Get a cloneable sender handle for publishing inbound messages.

Channel adapters should clone this sender so that multiple producers (e.g. Telegram, Slack, Discord) can publish concurrently.

pub fn outbound_sender(&self) -> Sender<OutboundMessage>

Get a cloneable sender handle for dispatching outbound messages.

Pipeline stages or agent tasks can clone this sender for concurrent outbound dispatch.

Trait Implementations

impl Default for MessageBus

fn default() -> Self

Returns the “default value” for a type.