Struct MessageBus 

pub struct MessageBus { /* private fields */ }

Message bus for agent communication

Following London School TDD:

• Agents don’t call each other directly
• All communication goes through the message bus
• Easy to mock for testing

Implementations

impl MessageBus

pub fn new() -> Self

Create a new message bus

pub fn register(&mut self, agent_id: AgentId) -> UnboundedReceiver<Message>

Register an agent with the message bus

pub fn unregister(&mut self, agent_id: &AgentId)

Unregister an agent from the message bus

pub async fn send(&self, message: Message) -> Result<()>

Send a message to a specific agent

pub async fn broadcast(&self, message: Message) -> Result<()>

Broadcast a message to all registered agents

pub fn agent_count(&self) -> usize

Get the number of registered agents

Trait Implementations

impl Default for MessageBus

fn default() -> Self

Returns the “default value” for a type.