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]
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,
fn pack(msg: M, tx: Option<SyncSender<M::Result>>) -> SyncEnvelope<A>
[src]
fn pack(msg: M, tx: Option<SyncSender<M::Result>>) -> SyncEnvelope<A>
Pack message into suitable envelope
impl<A: Actor> Destination<A> for Syn
[src]
impl<A: Actor> Destination<A> for Syn
type Transport = SyncAddressSender<A>
fn connected(tx: &Self::Transport) -> bool
[src]
fn connected(tx: &Self::Transport) -> bool
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]
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,
type Envelope = SyncEnvelope<A>
type ResultSender = Sender<M::Result>
type ResultReceiver = Receiver<M::Result>
fn do_send(tx: &Self::Transport, msg: M)
[src]
fn do_send(tx: &Self::Transport, msg: M)
Send message unconditionally
fn try_send(tx: &Self::Transport, msg: M) -> Result<(), SendError<M>>
[src]
fn try_send(tx: &Self::Transport, msg: M) -> Result<(), SendError<M>>
Try send message
fn send(tx: &Self::Transport, msg: M) -> Request<Self, A, M>
[src]
fn send(tx: &Self::Transport, msg: M) -> Request<Self, A, M>
Send asynchronous message and wait for response.
fn recipient(tx: Self::Transport) -> Recipient<Self, M>
[src]
fn recipient(tx: Self::Transport) -> Recipient<Self, M>
Get recipient for specific message type.
impl<M> MessageRecipient<M> for Syn where
M: Message + Send + 'static,
M::Result: Send,
[src]
impl<M> MessageRecipient<M> for Syn where
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]
fn do_send(tx: &Self::Transport, msg: M) -> Result<(), SendError<M>>
Send message unconditionally Read more
fn try_send(tx: &Self::Transport, msg: M) -> Result<(), SendError<M>>
[src]
fn try_send(tx: &Self::Transport, msg: M) -> Result<(), SendError<M>>
Try send message Read more
fn send(tx: &Self::Transport, msg: M) -> SyncRecipientRequest<M>
[src]
fn send(tx: &Self::Transport, msg: M) -> SyncRecipientRequest<M>
Send asynchronous message and wait for response. Read more
fn clone(tx: &Self::Transport) -> Self::Transport
[src]
fn clone(tx: &Self::Transport) -> Self::Transport
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]
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,
fn pack(msg: M, tx: Option<SyncSender<M::Result>>) -> SyncEnvelope<A>
[src]
fn pack(msg: M, tx: Option<SyncSender<M::Result>>) -> SyncEnvelope<A>
Pack message into suitable envelope