Struct MessageBus 

pub struct MessageBus { /* private fields */ }

An inter-agent message bus supporting publish/subscribe and history.

Implementations

impl MessageBus

pub fn new() -> Self

pub async fn send(&self, msg: AgentMessage)

Send a message. Stores in history with bounded eviction and notifies relevant subscribers.

pub fn with_capacity(cap: usize) -> Self

Create a MessageBus with a custom capacity (for testing).

pub async fn subscribe(&self, role: &str) -> Receiver<AgentMessage>

Subscribe to messages for a given role. Returns a broadcast receiver.

pub async fn inbox(&self, role: &str) -> Vec<AgentMessage>

Get all messages addressed to this role (including broadcasts).

pub async fn outbox(&self, role: &str) -> Vec<AgentMessage>

Get all messages sent by this role.

pub async fn history(&self) -> VecDeque<AgentMessage>

Get the full message history (bounded to MESSAGE_BUS_CAPACITY).

pub async fn clear(&self)

Clear all stored messages.

Trait Implementations

impl Clone for MessageBus

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MessageBus

fn default() -> Self

Returns the “default value” for a type.