Struct Bus 

pub struct Bus { /* private fields */ }

Implementations

impl Bus

pub fn new(capacity: usize) -> Self

Examples found in repository

examples/base.rs (line 23)

async fn main() {
    let bus = Bus::new(2);

    // Register EventA listener
    let handle1 = bus.bind::<EventA>(once(|_| async {
        println!("Handled  Event A");
    }));

    // Register EventB listener
    let handle2 = bus.bind(on(|_: EventB| async {
        println!("Handled  Event B");
    }));

    // Register EventC listener
    let handle3 = bus.bind(many(3, event_c_listener));

    // Emit events
    bus.emit(EventA).await;
    bus.emit(EventB).await;
    bus.emit(EventC).await;
    bus.emit(EventD).await;

    // Cancel EventB listener and register EventD listener
    handle2.cancel();
    tokio::time::sleep(Duration::from_millis(1)).await;
    let handle4 = bus.bind(on(|_: EventD| async {
        println!("Handled  Event D");
    }));

    // Emit again
    bus.emit(EventA).await;
    bus.emit(EventB).await;
    bus.clone().emit(EventD).await;

    drop(bus);

    let _ = join!(handle1, handle3, handle4);
}

pub fn bind<E: Event>( &self, listener: impl Listener<Event = E>, ) -> SubscribeHandle

Examples found in repository

examples/base.rs (lines 26-28)

async fn main() {
    let bus = Bus::new(2);

    // Register EventA listener
    let handle1 = bus.bind::<EventA>(once(|_| async {
        println!("Handled  Event A");
    }));

    // Register EventB listener
    let handle2 = bus.bind(on(|_: EventB| async {
        println!("Handled  Event B");
    }));

    // Register EventC listener
    let handle3 = bus.bind(many(3, event_c_listener));

    // Emit events
    bus.emit(EventA).await;
    bus.emit(EventB).await;
    bus.emit(EventC).await;
    bus.emit(EventD).await;

    // Cancel EventB listener and register EventD listener
    handle2.cancel();
    tokio::time::sleep(Duration::from_millis(1)).await;
    let handle4 = bus.bind(on(|_: EventD| async {
        println!("Handled  Event D");
    }));

    // Emit again
    bus.emit(EventA).await;
    bus.emit(EventB).await;
    bus.clone().emit(EventD).await;

    drop(bus);

    let _ = join!(handle1, handle3, handle4);
}

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

Examples found in repository

examples/base.rs (line 39)

async fn main() {
    let bus = Bus::new(2);

    // Register EventA listener
    let handle1 = bus.bind::<EventA>(once(|_| async {
        println!("Handled  Event A");
    }));

    // Register EventB listener
    let handle2 = bus.bind(on(|_: EventB| async {
        println!("Handled  Event B");
    }));

    // Register EventC listener
    let handle3 = bus.bind(many(3, event_c_listener));

    // Emit events
    bus.emit(EventA).await;
    bus.emit(EventB).await;
    bus.emit(EventC).await;
    bus.emit(EventD).await;

    // Cancel EventB listener and register EventD listener
    handle2.cancel();
    tokio::time::sleep(Duration::from_millis(1)).await;
    let handle4 = bus.bind(on(|_: EventD| async {
        println!("Handled  Event D");
    }));

    // Emit again
    bus.emit(EventA).await;
    bus.emit(EventB).await;
    bus.clone().emit(EventD).await;

    drop(bus);

    let _ = join!(handle1, handle3, handle4);
}

pub fn emitter<E: Event>(&self) -> Emitter<E>

Trait Implementations

impl Clone for Bus

fn clone(&self) -> Bus

Returns a duplicate of the value.

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

Performs copy-assignment from source.