Struct xtra_addons::Broker

pub struct Broker<T> where
    T: Message<Result = ()> + Clone,  { /* fields omitted */ }

Implementations

impl<T> Broker<T> where
    T: Message<Result = ()> + Clone, 

pub fn new() -> Self

pub async fn subscribe<A: Actor + Handler<T>>(
    subscriber: Address<A>
) -> Result<Subscription<T>, ()>

pub async fn publish(message: T) -> Result<(), Disconnected>

Trait Implementations

impl<T> Actor for Broker<T> where
    T: Message<Result = ()> + Clone, 

#[must_use]pub fn started<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    ctx: &'life1 mut Context<Self>
) -> Pin<Box<dyn Future<Output = ()> + 'async_trait + Send, Global>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Called as soon as the actor has been started.

#[must_use]pub fn stopping<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    ctx: &'life1 mut Context<Self>
) -> Pin<Box<dyn Future<Output = KeepRunning> + 'async_trait + Send, Global>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Called when the actor calls the Context::stop. This method can prevent the actor from stopping by returning KeepRunning::Yes. If this method returns KeepRunning::StopSelf, this actor will be stopped. If it returns KeepRunning::StopAll, then all actors on the same address as this actor will be stopped. This can take a little bit of time to propagate.

#[must_use]pub fn stopped<'life0, 'async_trait>(
    &'life0 mut self
) -> Pin<Box<dyn Future<Output = ()> + 'async_trait + Send, Global>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Called when the actor is in the process of stopping. This could be because KeepRunning::StopAll or KeepRunning::StopSelf was returned from the Actor::stopping method, or because there are no more strong addresses (Address, as opposed to WeakAddress. This should be used for any final cleanup before the actor is dropped.

pub fn create(self, message_cap: Option<usize>) -> ActorManager<Self>

Returns the actor's address and manager in a ready-to-start state, given the cap for the actor's mailbox. If None is passed, it will be of unbounded size. To spawn the actor, the ActorManager::spawn must be called, or the ActorManager::run method must be called and the future it returns spawned onto an executor.

impl<T> Default for Broker<T> where
    T: Message<Result = ()> + Clone, 

fn default() -> Self

Returns the "default value" for a type.