Struct Address 

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

Implementations

impl<A: Actor> Address<A>

pub async fn send<M: Message + 'static>( &self, message: M, ) -> Result<M::Result, ActorSendError>

where A: Handler<M>,

pub async fn send_unpack<M: Message + 'static, R>( &self, message: M, ) -> Result<R, ActorSendError>

where A: Handler<M>, M::Result: UnpackableResult<UnpackedResult = R>,

Sends a message and unpacks the result

Simplifies operations with some common kinds of results. Unpacks:

• tokio::oneshot::Receiver<T> into T
• Result<tokio::oneshot::Receiver<Result<T, E>, E> into Result<T, E>

It could be useful when you need to return Receiver<T> from handler immediately unblocking actors message loop to send T later.

pub fn is_closed(&self) -> bool

Returns true if the actor do not receive messages any more.

pub fn downgrade(&self) -> WeakAddress<A>

Converts the Address to a [WeakAddress] that does not count towards RAII semantics, i.e. if all Address instances of the actor were dropped and only WeakAddress instances remain, the actor is stopped.

pub fn is_connected(&self) -> bool

Returns true if actor is steel receiving messages.

The opposite of is_closed

Trait Implementations

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

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.