Struct MessageBus 

pub struct MessageBus { /* private fields */ }

The host-side message bus connecting execution contexts.

Messages are queued and delivered when the receiving context runs its next execution pass. The bus records all messages for the observation stream, up to a configurable cap.

Implementations

impl MessageBus

pub fn new() -> Self

pub fn send(&mut self, message: ContextMessage)

Queue a message for delivery to the target context.

Messages beyond the history or per-queue cap are silently discarded to prevent memory exhaustion from adversarial scripts.

pub fn receive(&mut self, context: &ContextId) -> Vec<ContextMessage>

Drain all pending messages for a context. Called when the context starts its next execution pass.

pub fn history(&self) -> &[ContextMessage]

Return the full message history for observation.

pub fn has_pending(&self) -> bool

Whether any context has pending messages.

pub fn history_len(&self) -> usize

Number of messages recorded in the history.

Trait Implementations

impl Debug for MessageBus

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MessageBus

fn default() -> MessageBus

Returns the “default value” for a type.