Struct actix::SyncAddress

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

Methods

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

fn send<M: 'static + Send>(&self, msg: M) where
    A: MessageHandler<M>,
    A::Item: Send,
    A::Error: Send, 

fn call<B: Actor, M: 'static + Send>(&self, msg: M) -> MessageResult<A, B, M> where
    A: MessageHandler<M>,
    A::Item: Send,
    A::Error: Send, 

fn subscriber<M: 'static + Send>(&self) -> Box<Subscriber<M>> where
    A: MessageHandler<M>,
    A::Item: Send,
    A::Error: Send, 

fn async_subscriber<M>(
    &self
) -> Box<AsyncSubscriber<M, Future = CallResult<A::Item, A::Error>>> where
    A: MessageHandler<M>,
    A::Item: Send,
    A::Error: Send,
    M: 'static + Send, 

Trait Implementations

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
    M: 'static + Send,
    A::Item: Send,
    A::Error: Send,
    A: Actor + MessageHandler<M>, 

fn send(&self, msg: M)

Buffered send

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

Unbuffered send

impl<A, M> AsyncSubscriber<M> for SyncAddress<A> where
    M: 'static + Send,
    A: Actor + MessageHandler<M>,
    A::Item: Send,
    A::Error: Send, 

type Future = CallResult<A::Item, A::Error>

fn call(&self, msg: M) -> Self::Future

Send message, wait response asynchronously

fn unbuffered_call(&self, msg: M) -> Result<Self::Future, M>

Send message, wait response asynchronously