Struct MpscDispatcher 

pub struct MpscDispatcher { /* private fields */ }

An object that register reactive::Behavior and dispatch messages for them.

The proper way to construct it is to use Builder.

Implementations

impl MpscDispatcher

pub fn process(&mut self)

Process messages until dispatcher::Request::StopDispatcher is received.

Trait Implementations

impl Dispatcher for MpscDispatcher

fn addr(&self) -> Addr

Return the actor address of the dispatcher itself.

fn register_reactive(&mut self, behavior: Box<dyn Behavior>) -> Addr

Migrate a reactive inside the dispatcher and return an actor address to it.

fn replace_reactive( &mut self, addr: &Addr, behavior: Box<dyn Behavior>, ) -> Result<Box<dyn Behavior>, Box<dyn Behavior>>

Replace an implementation of a reactive by a new one. This only change the object that responds to process message. This is thread safe but of course the management of new and old inner states transition should be taken into account. All copies of the address are still valid.

fn unregister_reactive(&mut self, addr: &Addr) -> Option<Box<dyn Behavior>>

Extract a reactive from the dispatcher by it address.

fn own_addr(&self) -> Addr

👎Deprecated: use the better named addr()

impl Drop for MpscDispatcher

fn drop(&mut self)

Executes the destructor for this type.