Struct EventBus 

pub struct EventBus { /* private fields */ }

Async event bus for broadcasting execution events to multiple subscribers.

Uses tokio’s broadcast channel internally. Subscribers receive all events emitted after they subscribe. Events are cloned for each subscriber.

Implementations

impl EventBus

pub fn new(capacity: usize) -> Self

Create a new event bus with the given channel capacity.

pub fn emit(&self, event: Event) -> usize

Emit an event to all subscribers. Returns the number of receivers that received the event. If there are no subscribers, the event is silently dropped.

pub fn subscribe(&self) -> Receiver<Event>

Subscribe to receive events.

pub fn subscriber_count(&self) -> usize

Number of active subscribers.

Trait Implementations

impl Default for EventBus

fn default() -> Self

Returns the “default value” for a type.