Struct MailboxMuxer 

pub struct MailboxMuxer { /* private fields */ }

An in-memory mailbox muxer. This is used to route messages to different underlying senders.

Messages for an actor that has not yet bound are buffered and delivered, in order, when it binds. If the actor does not bind within crate::config::PENDING_ACTOR_DELIVERY_TIMEOUT, they are returned as undeliverable with InvalidReferenceReason::ActorNotExist.

Implementations

impl MailboxMuxer

pub fn new() -> Self

Create a new, empty, muxer.

pub fn bind( &self, actor_id: ActorId, sender: impl MailboxSender + 'static, ) -> bool

Route messages destined for the provided actor id to the provided sender, first delivering any messages buffered for the actor. Returns false if the actor is already bound. In this case, the sender is not replaced, and the caller must MailboxMuxer::unbind it first.

pub fn bind_mailbox(&self, mailbox: Mailbox) -> bool

Convenience function to bind a mailbox.

pub fn bind_status(&self, sender: impl MailboxSender + 'static) -> bool

Route status messages to the provided sender, regardless of the destination actor’s liveness.

Trait Implementations

impl Clone for MailboxMuxer

fn clone(&self) -> MailboxMuxer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MailboxMuxer

fn default() -> Self

Returns the “default value” for a type.

impl MailboxSender for MailboxMuxer

fn post_unchecked( &self, envelope: MessageEnvelope, return_handle: PortHandle<Undeliverable<MessageEnvelope>>, )

Raw transport: no policy.

fn flush<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Wait until all messages previously posted through this sender have been delivered (wire-acked) or confirmed undeliverable. The default implementation is a no-op, appropriate for senders whose post is synchronous (e.g. local in-process delivery).

fn post( &self, envelope: MessageEnvelope, return_handle: PortHandle<Undeliverable<MessageEnvelope>>, )

Apply hop semantics (TTL decrement; undeliverable on 0), then delegate to transport.