Struct actix::Addr

pub struct Addr<T: Destination<A>, A> { /* fields omitted */ }

Address of the actor

Methods

impl<T: Destination<A>, A> Addr<T, A>

pub fn new(tx: T::Transport) -> Addr<T, A>

pub fn connected(&self) -> bool

Indicates if actor is still alive

pub fn do_send<M>(&self, msg: M) where
    T: MessageDestination<A, M>,
    T::Transport: MessageDestinationTransport<T, A, M>,
    M: Message + 'static,
    A: Handler<M>,
    A::Context: ToEnvelope<T, A, M>, 

Send message unconditionally

This method ignores actor's mailbox capacity, it silently fails if mailbox is closed.

pub fn send<M>(&self, msg: M) -> Request<T, A, M> where
    T: MessageDestination<A, M>,
    T::Transport: MessageDestinationTransport<T, A, M>,
    M: Message + 'static,
    A: Handler<M>,
    A::Context: ToEnvelope<T, 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 try_send<M>(&self, msg: M) -> Result<(), SendError<M>> where
    T: MessageDestination<A, M>,
    T::Transport: MessageDestinationTransport<T, A, M>,
    M: Message + 'static,
    A: Handler<M>,
    A::Context: ToEnvelope<T, A, M>, 

Try to send message

This method fails if actor's mailbox is full or closed. This method register current task in receivers queue.

pub fn recipient<M>(self) -> Recipient<T, M> where
    T: MessageDestination<A, M> + MessageRecipient<M>,
    A: Handler<M>,
    A::Context: ToEnvelope<T, A, M>,
    <T as Destination<A>>::Transport: MessageDestinationTransport<T, A, M>,
    M: Message + 'static, 

Get Recipient for specific message type

Trait Implementations

impl<A, M, B> MessageResponse<A, M> for Addr<Syn, B> where
    A: Actor,
    M: Message<Result = Addr<Syn, B>>,
    B: Actor<Context = Context<B>>, 

fn handle<R: ResponseChannel<M>>(self, _: &mut A::Context, tx: Option<R>)

impl<A> ActorAddress<A, Addr<Unsync, A>> for A where
    A: Actor,
    A::Context: AsyncContext<A>, 

fn get(ctx: &mut A::Context) -> Addr<Unsync, A>

Returns actor's address for specific context

impl<A> ActorAddress<A, Addr<Syn, A>> for A where
    A: Actor,
    A::Context: AsyncContext<A>, 

fn get(ctx: &mut A::Context) -> Addr<Syn, A>

Returns actor's address for specific context

impl<A: Actor> Send for Addr<Syn, A>

impl<A: Actor> Sync for Addr<Syn, A>

impl<T: Destination<A>, A> Clone for Addr<T, A>

fn clone(&self) -> Addr<T, A>

Returns a copy of the value.

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

Performs copy-assignment from source.