Struct MessageBus 

pub struct MessageBus { /* private fields */ }

Broadcast-based message bus for inter-agent communication.

Agents subscribe to the bus and receive messages addressed to them or broadcast messages. Thread-safe and async-compatible.

Implementations

impl MessageBus

pub fn new(capacity: usize) -> Self

Create a new message bus with the given channel capacity.

pub fn publish(&self, msg: InterAgentMessage) -> PublishResult

Publish a message to the bus.

Returns a PublishResult indicating how many receivers received the message, or whether the message was dropped due to no subscribers. A warning is logged when messages are dropped.

pub fn subscribe(&self) -> Receiver<InterAgentMessage>

Subscribe to all messages on the bus.

Warning: The raw broadcast receiver will silently drop messages if the receiver lags behind. Consider using subscribe_lag_aware instead.

pub fn subscribe_lag_aware(&self) -> LagAwareReceiver

Subscribe with automatic lag handling.

Returns a LagAwareReceiver that logs a warning when messages are skipped due to the receiver falling behind.

pub fn subscriber_count(&self) -> usize

Get the number of active subscribers.

pub fn capacity(&self) -> usize

Get the configured capacity.

Trait Implementations

impl Clone for MessageBus

fn clone(&self) -> MessageBus

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.