Struct EventBus 

pub struct EventBus { /* private fields */ }

Event bus for broadcasting data events

Uses tokio::broadcast for multi-consumer support. TUI subscribes for redraw triggers, Web uses for SSE push.

Implementations

impl EventBus

pub fn new(capacity: usize) -> Self

Create a new event bus with specified channel capacity

pub fn default_capacity() -> Self

Create with default capacity (256 events)

pub fn publish(&self, event: DataEvent)

Publish an event to all subscribers

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

Subscribe to receive events

pub fn subscriber_count(&self) -> usize

Get current number of active subscribers

Trait Implementations

impl Clone for EventBus

fn clone(&self) -> Self

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.