Struct actix::SyncAddress

pub struct SyncAddress<A> where
    A: Actor,  { /* fields omitted */ }

Send address of the actor. Actor can run in different thread

Methods

impl<A> SyncAddress<A> where
    A: Actor, 

fn connected(&self) -> bool

Indicates if address is still connected to the actor.

fn send<M>(&self, msg: M) where
    A: Handler<M>,
    <A as Actor>::Context: ToEnvelope<A>,
    M: ResponseType + Send + 'static,
    M::Item: Send,
    M::Error: Send, 

Send message M to actor A. Message cold be sent to actor running in different thread.

fn call<B: Actor, M>(&self, _: &B, msg: M) -> Request<B, M> where
    A: Handler<M>,
    M: ResponseType + Send + 'static,
    M::Item: Send,
    M::Error: Send,
    <A as Actor>::Context: ToEnvelope<A>, 

Send message to actor A and asynchronously wait for response.

if returned Request object get dropped, message cancels.

fn call_fut<M>(&self, msg: M) -> SyncReceiver<Result<M::Item, M::Error>> where
    A: Handler<M>,
    M: ResponseType + Send + 'static,
    M::Item: Send,
    M::Error: Send,
    <A as Actor>::Context: ToEnvelope<A>, 

Send message to actor A and asynchronously wait for response.

if returned Receiver object get dropped, message cancels.

fn subscriber<M: 'static + Send>(&self) -> Box<Subscriber<M> + Send> where
    A: Handler<M>,
    M: ResponseType + Send + 'static,
    M::Item: Send,
    M::Error: Send,
    <A as Actor>::Context: ToEnvelope<A>, 

Get Subscriber for specific message type

Trait Implementations

impl<A> Send for SyncAddress<A> where
    A: Actor, 

impl<A> Sync for SyncAddress<A> where
    A: Actor, 

impl<A> Clone for SyncAddress<A> where
    A: Actor, 

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<A, M> Subscriber<M> for SyncAddress<A> where
    A: Actor + Handler<M>,
    <A as Actor>::Context: ToEnvelope<A>,
    M: ResponseType + Send + 'static,
    M::Item: Send,
    M::Error: Send, 

fn send(&self, msg: M) -> Result<(), M>

Send buffered message