Struct EventBus 

pub struct EventBus { /* private fields */ }

Implementations

impl EventBus

pub fn new(spawner: &ActorSpawner) -> Self

pub fn register<E, L>(&self, listener: L)

where E: Event, L: EventListener<E>,

pub fn emit<E>(&self, event: E)

where E: Event,

pub fn wait_for_completion(&self)

Waits until the bus has drained everything queued ahead of this call.

Off dst the bus actor runs on its own thread (host) or inline on send (wasm), so a blocking receive is both correct and the cheapest way to wait.

Trait Implementations

impl Clone for EventBus

fn clone(&self) -> EventBus

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.