Struct StreamBus 

pub struct StreamBus { /* private fields */ }

In-process event bus for max/stream subscriptions. Backed by tokio::sync::broadcast.

Implementations

impl StreamBus

pub fn new(capacity: usize) -> Self

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

pub fn publish(&self, event: StreamEvent) -> usize

Publish an event to all current subscribers. Returns the receiver count.

pub fn subscriber_count(&self) -> usize