Struct apalis_core::worker::Addr

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

Available on crate feature worker only.

Address of actor. Can be used to send messages to it.

Implementations

impl<W: Actor> Addr<W>

pub async fn send<M>(&self, message: M) -> Result<M::Result, RecvError>where
    M: Message + Send + 'static,
    M::Result: Send,
    W: ContextHandler<M>,

Send a message and wait for an answer.

Errors

Fails if noone will send message

Panics

If queue is full

pub async fn do_send<M>(&self, message: M) -> Option<M::Result>where
    M: Message + Send + 'static,
    M::Result: Send,
    W: ContextHandler<M>,

Send a message and wait for an answer.

Errors

Fails if queue is full or actor is disconnected

pub fn recipient<M>(&self) -> Recipient<M>where
    M: Message + Send + 'static,
    W: ContextHandler<M>,
    M::Result: Send,

Constructs recipient for sending only specific messages

pub fn expect_running(self) -> AlwaysAddr<W>

Contstructs address which will never panic on sending.

Beware: You need to make sure that this actor will be always alive

Trait Implementations

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

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<A: Debug + Actor> Debug for Addr<A>

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

Formats the value using the given formatter.