Struct Mailbox 

pub struct Mailbox<A: Actor> { /* private fields */ }

A typed reference to an actor in a cluster.

Implementations

impl<A: Actor> Mailbox<A>

pub async fn call<M, R>(&self, message: M) -> Result<R, CallError<M>>

where A: Handler<Call<M, R>>, M: Message, R: Message,

Sends a request and waits for the actor’s reply.

impl<A: Actor> Mailbox<A>

pub fn name(&self) -> Option<&str>

Returns the actor’s registered name.

pub fn send<M>(&self, message: M) -> Result<(), DeliverError<M>>

where A: Handler<M>, M: Message,

Enqueues a message handled by this actor without waiting.

pub fn broker<M>(&self) -> Broker<M>

where A: Handler<M>, M: Message,

Creates a send-only capability for one message type.

pub fn stop(&self) -> bool

Requests a graceful stop, returning whether this call requested it.

pub fn is_closed(&self) -> bool

Returns whether the mailbox rejects new messages.

pub fn capacity(&self) -> NonZeroUsize

Returns the fixed mailbox capacity.

Trait Implementations

impl<A: Actor> Clone for Mailbox<A>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A: Actor> Debug for Mailbox<A>

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

Formats the value using the given formatter.