Struct StoreMailbox 

pub struct StoreMailbox { /* private fields */ }

A mailbox kept in the actor’s graph store, in graph <address>/mailbox: it survives restarts, and its messages are delivered again in their original order.

Implementations

impl StoreMailbox

pub fn open(address: Address, storage: Arc<dyn Storage>) -> Self

Opens the mailbox of address, loading the messages stored for it.

Trait Implementations

impl Debug for StoreMailbox

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

Formats the value using the given formatter.

impl Mailbox for StoreMailbox

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.