Struct UnboundedAddress

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

Implementations

impl<A: Actor> UnboundedAddress<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

pub fn notify<M: Message + 'static>( &self, message: M, ) -> Result<(), FailedToDeliver>

where A: Handler<M>,

pub fn notify_later<M: Message + 'static>(&self, message: M, after: Duration)

where A: Handler<M>,

pub fn notify_at<M: Message + 'static>(&self, message: M, at: Instant)

where A: Handler<M>,

pub fn notify_interval<M: Message + 'static, F: Fn() -> M + Send + 'static>( &self, create_message: F, period: Duration, ) -> JoinHandle<()>

where A: Handler<M>,

pub fn is_closed(&self) -> bool

Trait Implementations

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

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.