Struct apalis_core::worker::AlwaysAddr

pub struct AlwaysAddr<A: Actor>(_);

Available on crate feature worker only.

Address of an actor which is always alive.

Implementations

impl<A: Actor> AlwaysAddr<A>

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

Send a message and wait for an answer.

Methods from Deref<Target = Addr<A>>

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

Trait Implementations

impl<A: Actor> Clone for AlwaysAddr<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 AlwaysAddr<A>

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

Formats the value using the given formatter.

impl<A: Actor> Deref for AlwaysAddr<A>

type Target = Addr<A>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<A: Actor> DerefMut for AlwaysAddr<A>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.