Struct MessageBus 

pub struct MessageBus { /* private fields */ }

Message bus for inter-slot communication.

Implements a simple inbox-based messaging system where each slot has a queue of messages addressed to it.

Implementations

impl MessageBus

pub fn new() -> Self

Create a new message bus.

pub fn send(&self, from: SlotId, to: SlotId, content: String) -> String

Send a message from one slot to another, returning the message ID.

pub fn read(&self, slot_id: &SlotId) -> Vec<Message>

Read and drain all messages for a slot, returning them in order.

pub fn peek(&self, slot_id: &SlotId) -> Vec<Message>

Peek at all messages for a slot without removing them.

pub fn broadcast( &self, from: SlotId, recipients: &[SlotId], content: String, ) -> Vec<String>

Broadcast a message from one slot to all other slots.

Sends a copy of the message to every slot in recipients except the sender. Returns the list of message IDs created.

pub fn count(&self, slot_id: &SlotId) -> usize

Get the count of messages in a slot’s inbox.

Trait Implementations

impl Default for MessageBus

fn default() -> Self

Returns the “default value” for a type.