Struct tonari_actor::Recipient

pub struct Recipient<M> { /* private fields */ }

Similar to Addr, but rather than pointing to a specific actor, it is typed for any actor that handles a given message-response type.

Implementations

impl<M> Recipient<M>

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

Send a message to an actor. Returns SendError if the channel is full; does not block. See SendResultExt trait for convenient handling of errors.

impl<M: 'static> Recipient<M>

pub fn recipient<N: Into<M>>(&self) -> Recipient<N>

Convert a Recipient<M> (or Addr<A> through Deref, where A::Message = M) into Recipient<N>, where message N can be converted into M.

In case of converting from Addr, this erases the type of the actor and only preserves type of the message, allowing you to make actors more independent of each other.

Trait Implementations

impl<M> Clone for Recipient<M>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<M> RecipientExt<M> for Recipient<TimedMessage<M>>

fn send_now(&self, message: M) -> Result<(), SendError>

Send a message now. Convenience to wrap message in TimedMessage::Instant.

fn send_timed(&self, message: M, fire_at: Instant) -> Result<(), SendError>

Send a message to be delivered later at a certain instant.

fn send_recurring( &self, factory: impl FnMut() -> M + Send + 'static, fire_at: Instant, interval: Duration, ) -> Result<(), SendError>

Schedule sending of message at fire_at plus at regular intervals from that point on.

fn send_delayed(&self, message: M, delay: Duration) -> Result<(), SendError>

Send a message to be delivered later after some time from now.