Trait actix_broker::BrokerIssue[−][src]

pub trait BrokerIssue where
    Self: Actor,
    Self::Context: AsyncContext<Self>, {
    fn issue_async<M: BrokerMsg>(&self, msg: M)
    where
        <M as Message>::Result: Send,
    { ... }
    fn issue_sync<M: BrokerMsg>(&self, msg: M, ctx: &mut Self::Context)
    where
        <M as Message>::Result: Send,
    { ... }
}

The BrokerIssue provides functions to issue messages to any subscribers.

Provided Methods

`fn issue_async<M: BrokerMsg>(&self, msg: M) where <M as Message>::Result: Send,`

Asynchronously issue a message.

`fn issue_sync<M: BrokerMsg>(&self, msg: M, ctx: &mut Self::Context) where <M as Message>::Result: Send,`

Synchronously issue a message. This also causes the broker to synchronously forward those messages on to any subscribers before handling any other messages.

Implementors

impl<A> BrokerIssue for A where A: Actor, <A as Actor>::Context: AsyncContext<A>,
[src]