Struct EventBus 

pub struct EventBus { /* private fields */ }

Simple async event bus (pub/sub).

let bus = EventBus::new();

bus.on::<UserCreated>(|event| async move {
    println!("User created: {}", event.email);
}).await;

bus.emit(UserCreated { user_id: 1, email: "foo@bar.com".into() }).await;

Implementations

impl EventBus

pub fn new() -> Self

pub async fn on<E, F, Fut>(&self, handler: F)

where E: Event, F: Fn(Arc<E>) -> Fut + Send + Sync + 'static, Fut: Future<Output = ()> + Send + 'static,

Register a handler for an event type

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

Emit an event, calling all registered handlers concurrently

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.

impl Default for EventBus

fn default() -> Self

Returns the “default value” for a type.