Struct actix::Syn
[−]
[src]
pub struct Syn;
Sync destination of the actor. Actor can run in different thread
Trait Implementations
impl<A, M> ToEnvelope<Syn, A, M> for Context<A> where
A: Actor<Context = Context<A>> + Handler<M>,
M: Message + Send + 'static,
M::Result: Send, [src]
A: Actor<Context = Context<A>> + Handler<M>,
M: Message + Send + 'static,
M::Result: Send,
fn pack(msg: M, tx: Option<SyncSender<M::Result>>) -> SyncEnvelope<A>[src]
Pack message into suitable envelope
impl<A: Actor> Destination<A> for Syn[src]
type Transport = SyncAddressSender<A>
fn connected(tx: &Self::Transport) -> bool[src]
Indicates if actor is still alive
impl<A: Actor, M> MessageDestination<A, M> for Syn where
A: Handler<M>,
A::Context: ToEnvelope<Self, A, M>,
M: Message + Send + 'static,
M::Result: Send, [src]
A: Handler<M>,
A::Context: ToEnvelope<Self, A, M>,
M: Message + Send + 'static,
M::Result: Send,
type Envelope = SyncEnvelope<A>
type ResultSender = Sender<M::Result>
type ResultReceiver = Receiver<M::Result>
fn do_send(tx: &Self::Transport, msg: M)[src]
Send message unconditionally
fn try_send(tx: &Self::Transport, msg: M) -> Result<(), SendError<M>>[src]
Try send message
fn send(tx: &Self::Transport, msg: M) -> Request<Self, A, M>[src]
Send asynchronous message and wait for response.
fn recipient(tx: Self::Transport) -> Recipient<Self, M>[src]
Get recipient for specific message type.
impl<M> MessageRecipient<M> for Syn where
M: Message + Send + 'static,
M::Result: Send, [src]
M: Message + Send + 'static,
M::Result: Send,
type Transport = Box<SyncSender<M>>
type Envelope = SyncMessageEnvelope<M>
type SendError = SendError<M>
type MailboxError = MailboxError
type Request = SyncRecipientRequest<M>
fn do_send(tx: &Self::Transport, msg: M) -> Result<(), SendError<M>>[src]
Send message unconditionally Read more
fn try_send(tx: &Self::Transport, msg: M) -> Result<(), SendError<M>>[src]
Try send message Read more
fn send(tx: &Self::Transport, msg: M) -> SyncRecipientRequest<M>[src]
Send asynchronous message and wait for response. Read more
fn clone(tx: &Self::Transport) -> Self::Transport[src]
Clone transport
impl<A, M> ToEnvelope<Syn, A, M> for SyncContext<A> where
A: Actor<Context = SyncContext<A>> + Handler<M>,
M: Message + Send + 'static,
M::Result: Send, [src]
A: Actor<Context = SyncContext<A>> + Handler<M>,
M: Message + Send + 'static,
M::Result: Send,
fn pack(msg: M, tx: Option<SyncSender<M::Result>>) -> SyncEnvelope<A>[src]
Pack message into suitable envelope