Struct LinkMailbox 

pub struct LinkMailbox { /* private fields */ }

The runtime’s view of an actor reached through a Link: a mailbox that offers each message to the link. It accepts a message once the peer acknowledged it; until then it reports the delivery as failed, so the outbox keeps the send and retries it. A send refused by the peer’s credential check is recorded as a dead letter (reason transport-refused) and settled.

Implementations

impl LinkMailbox

pub fn new(link: Arc<Link>, handle: Option<NodeHandle>) -> Self

A mailbox over link; handle records dead letters of refused sends.

Trait Implementations

impl Debug for LinkMailbox

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

Formats the value using the given formatter.

impl Mailbox for LinkMailbox

fn enqueue(&self, env: Envelope) -> Result<(), MailboxError>

Appends a message.

fn receive(&self, _deferred: &[String]) -> Option<Envelope>

The oldest message that is neither in flight nor deferred (its event name matches no descriptor in deferred), now marked in flight.

fn ack(&self, _message_id: &str) -> Result<(), MailboxError>

Removes the in-flight message message_id (its turn is durable).

fn release(&self, _message_id: &str)

Puts the in-flight message message_id back, to be received again.

fn release_all(&self)

Puts every in-flight message back.

fn pending(&self) -> Vec<Envelope>

Every message not yet acknowledged, in arrival order.

fn pending_deliverable(&self, _deferred: &[String]) -> usize

The number of messages that are neither in flight nor deferred.

fn has_deliverable(&self, deferred: &[String]) -> bool

True when Mailbox::receive would return a message.

fn len(&self) -> usize

The number of messages not yet acknowledged.

fn is_empty(&self) -> bool

True when every message is acknowledged.