Struct EventBus 

pub struct EventBus { /* private fields */ }

Event publisher held by the embed runtime.

EventBus is a thin wrapper around a tokio::sync::broadcast::Sender that drops events silently when no receivers are attached.

Implementations

impl EventBus

pub fn new(capacity: usize) -> Self

Build a fresh bus with the supplied channel capacity.

Examples

use dynomite::embed::events::EventBus;
let bus = EventBus::new(8);
assert_eq!(bus.subscriber_count(), 0);

pub fn subscribe(&self) -> EventStream

Subscribe a fresh receiver.

Examples

use dynomite::embed::events::EventBus;
let bus = EventBus::new(4);
let _rx = bus.subscribe();
assert!(bus.subscriber_count() >= 1);

pub fn subscriber_count(&self) -> usize

Number of attached subscribers.

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 Debug for EventBus

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.