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.

Two delivery paths with different guarantees:

• Sinks (add_sink) are invoked synchronously on the emitting thread before the broadcast — lossless and ordered. Trackers persist events through this path.
• Subscribers (subscribe) receive via the broadcast channel — live but lossy under lag. Display/relay only.

Implementations

impl EventBus

pub fn new(capacity: usize) -> Self

Create a new event bus with the given channel capacity.

pub fn add_sink(&self, sink: Arc<dyn EventSink>)

Register a lossless sink, called synchronously on every emit.

pub fn remove_sink(&self, sink: &Arc<dyn EventSink>)

Unregister a previously added sink (matched by identity). The sink is flushed before removal.

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

Emit an event: sinks first (lossless), then all subscribers. Returns the number of broadcast receivers that received the event. If there are no subscribers, the broadcast is silently dropped.

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

Subscribe to receive events.

pub fn subscriber_count(&self) -> usize

Number of active subscribers.

pub fn flush_sinks(&self)

Flush all registered sinks.

Trait Implementations

impl Default for EventBus

fn default() -> Self

Returns the “default value” for a type.