Struct Mailbox 

pub struct Mailbox { /* private fields */ }

Mailbox provides named channels for agent-to-agent messaging.

Each agent registers by name and gets a receiver. Messages are routed by the to field on the Message.

Implementations

impl Mailbox

pub fn new(buffer_size: usize) -> Self

pub async fn register(&self, name: &str) -> Receiver<Message>

Register an agent and return its message receiver.

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

Send a message to a named agent.

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

Broadcast a message to all registered agents.

pub async fn unregister(&self, name: &str)

Unregister an agent (drops its sender).

Trait Implementations

impl Default for Mailbox

fn default() -> Self

Returns the “default value” for a type.