Struct WorkerMailbox 

pub struct WorkerMailbox { /* private fields */ }

A FIFO queue of pending messages for a single worker agent.

The coordinator pushes messages here; the worker’s kernel drains them between steps.

Implementations

impl WorkerMailbox

pub fn new() -> Self

pub async fn push(&self, msg: String)

Push a message into the mailbox.

pub async fn pop(&self) -> Option<String>

Pop the oldest pending message, or None if empty.

pub async fn drain_all(&self) -> Vec<String>

Drain all pending messages into a Vec.

pub async fn len(&self) -> usize

Return the number of pending messages without consuming them.

pub async fn is_empty(&self) -> bool

Trait Implementations

impl Clone for WorkerMailbox

fn clone(&self) -> WorkerMailbox

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for WorkerMailbox

fn default() -> WorkerMailbox

Returns the “default value” for a type.