Struct MemoryMailbox 

pub struct MemoryMailbox { /* private fields */ }

An in-memory mailbox; its messages are lost with the process.

Trait Implementations

impl Debug for MemoryMailbox

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

Formats the value using the given formatter.

impl Default for MemoryMailbox

fn default() -> Self

Returns the “default value” for a type.

impl Mailbox for MemoryMailbox

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.