Struct Mailbox 

pub struct Mailbox { /* private fields */ }

MPSC mailbox for an actor.

Uses lock-free bounded queues internally. Backpressure is coordinated via a semaphore; async wakeup via Notify.

Implementations

impl Mailbox

pub fn new(actor_id: ActorId, config: MailboxConfig) -> Self

Create a new mailbox.

pub fn try_send(&self, message: Message) -> Result<(), (Message, Error)>

Try to send a message to the mailbox (non-blocking).

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

Send a message to the mailbox (async, waits if full).

pub fn try_recv(&self) -> Option<Message>

Receive a message from the mailbox (non-blocking).

pub async fn recv(&self) -> Message

Receive a message from the mailbox (async, waits if empty).

Uses tokio::sync::Notify for efficient wakeup instead of busy-polling. The Notified future is created and enabled before the emptiness check, so a notify_waiters racing with this call cannot be missed (lost-wakeup).

pub fn len(&self) -> usize

Get the current queue size.

pub fn is_empty(&self) -> bool

Check if the mailbox is empty.

pub fn is_backpressured(&self) -> bool

Check if the mailbox is in backpressure state.

pub fn capacity(&self) -> usize

Get the mailbox capacity.

pub fn remaining_capacity(&self) -> usize

Get remaining capacity.

pub fn clear(&self)

Clear all messages from the mailbox.