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 and notifies relevant subscribers.

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) -> Vec<AgentMessage>

Get the full message history.

pub async fn clear(&self)

Clear all stored messages.

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.

impl Default for MessageBus

fn default() -> Self

Returns the “default value” for a type.