Trait actix_broker::BrokerIssue [−][src]
pub trait BrokerIssue: Actor<Context = Context<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,
<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,
<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.