Struct actix_web::actix::actix::Addr [−]
pub struct Addr<A> where
A: Actor, { /* fields omitted */ }Address of the actor
Methods
impl<A> Addr<A> where
A: Actor,
impl<A> Addr<A> where
A: Actor, pub fn new(tx: AddressSender<A>) -> Addr<A>
pub fn new(tx: AddressSender<A>) -> Addr<A>pub fn connected(&self) -> bool
pub fn connected(&self) -> boolIndicates if actor is still alive
pub fn do_send<M>(&self, msg: M) where
A: Handler<M>,
M: Message + Send,
<M as Message>::Result: Send,
<A as Actor>::Context: ToEnvelope<A, M>,
pub fn do_send<M>(&self, msg: M) where
A: Handler<M>,
M: Message + Send,
<M as Message>::Result: Send,
<A as Actor>::Context: ToEnvelope<A, M>, Send message unconditionally
This method ignores actor's mailbox capacity, it silently fails if mailbox is closed.
pub fn try_send<M>(&self, msg: M) -> Result<(), SendError<M>> where
A: Handler<M>,
M: Message + Send + 'static,
<M as Message>::Result: Send,
<A as Actor>::Context: ToEnvelope<A, M>,
pub fn try_send<M>(&self, msg: M) -> Result<(), SendError<M>> where
A: Handler<M>,
M: Message + Send + 'static,
<M as Message>::Result: Send,
<A as Actor>::Context: ToEnvelope<A, M>, Try send message
This method fails if actor's mailbox is full or closed. This method register current task in receivers queue.
pub fn send<M>(&self, msg: M) -> Request<A, M> where
A: Handler<M>,
M: Message + Send,
<M as Message>::Result: Send,
<A as Actor>::Context: ToEnvelope<A, M>,
pub fn send<M>(&self, msg: M) -> Request<A, M> where
A: Handler<M>,
M: Message + Send,
<M as Message>::Result: Send,
<A as Actor>::Context: ToEnvelope<A, M>, Send asynchronous message and wait for response.
Communication channel to the actor is bounded. if returned Future
object get dropped, message cancels.
pub fn recipient<M>(self) -> Recipient<M> where
A: Handler<M>,
M: 'static + Message + Send,
<A as Actor>::Context: ToEnvelope<A, M>,
<M as Message>::Result: Send,
pub fn recipient<M>(self) -> Recipient<M> where
A: Handler<M>,
M: 'static + Message + Send,
<A as Actor>::Context: ToEnvelope<A, M>,
<M as Message>::Result: Send, Get Recipient for specific message type
Trait Implementations
impl<A> Eq for Addr<A> where
A: Actor,
impl<A> Eq for Addr<A> where
A: Actor, impl<A> PartialEq<Addr<A>> for Addr<A> where
A: Actor,
impl<A> PartialEq<Addr<A>> for Addr<A> where
A: Actor, fn eq(&self, other: &Addr<A>) -> bool
fn eq(&self, other: &Addr<A>) -> boolThis method tests for self and other values to be equal, and is used by ==. Read more
#[must_use]
fn ne(&self, other: &Rhs) -> bool1.0.0[src]
#[must_use]
fn ne(&self, other: &Rhs) -> boolThis method tests for !=.
impl<A> Hash for Addr<A> where
A: Actor,
impl<A> Hash for Addr<A> where
A: Actor, fn hash<H>(&self, state: &mut H) where
H: Hasher,
fn hash<H>(&self, state: &mut H) where
H: Hasher, Feeds this value into the given [Hasher]. Read more
fn hash_slice<H>(data: &[Self], state: &mut H) where
H: Hasher, 1.3.0[src]
fn hash_slice<H>(data: &[Self], state: &mut H) where
H: Hasher, Feeds a slice of this type into the given [Hasher]. Read more
impl<A> Clone for Addr<A> where
A: Actor,
impl<A> Clone for Addr<A> where
A: Actor, fn clone(&self) -> Addr<A>
fn clone(&self) -> Addr<A>Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)1.0.0[src]
fn clone_from(&mut self, source: &Self)Performs copy-assignment from source. Read more
impl<A, M, B> MessageResponse<A, M> for Addr<B> where
A: Actor,
B: Actor<Context = Context<B>>,
M: Message<Result = Addr<B>>,
impl<A, M, B> MessageResponse<A, M> for Addr<B> where
A: Actor,
B: Actor<Context = Context<B>>,
M: Message<Result = Addr<B>>, fn handle<R>(self, &mut <A as Actor>::Context, tx: Option<R>) where
R: ResponseChannel<M>,
fn handle<R>(self, &mut <A as Actor>::Context, tx: Option<R>) where
R: ResponseChannel<M>,