Struct actix::prelude::SyncAddress
[−]
[src]
pub struct SyncAddress<A> where
A: Actor, { /* fields omitted */ }
Send
address of the actor. Actor can run in differend thread
Methods
impl<A> SyncAddress<A> where
A: Actor,
[src]
A: Actor,
fn connected(&self) -> bool
[src]
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,
[src]
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>,
[src]
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 asyncronously wait for response.
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>,
[src]
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 asyncronously wait for response.
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>,
[src]
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,
[src]
A: Actor,
impl<A> Sync for SyncAddress<A> where
A: Actor,
[src]
A: Actor,
impl<A> Clone for SyncAddress<A> where
A: Actor,
[src]
A: Actor,
fn clone(&self) -> Self
[src]
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)
1.0.0[src]
Performs copy-assignment from source
. Read more
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,
[src]
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>
[src]
Send buffered message
fn subscriber(&self) -> Box<Subscriber<M>>
[src]
Clone subscriber