Struct EventBus 

pub struct EventBus<T: Clone + Send + 'static> { /* private fields */ }

Broadcast bus — fan one message out to every connected subscriber.

Slow consumers that fall behind the buffer get a RecvError::Lagged and skip messages — they don’t block other subscribers. The default buffer size is 100 messages.

Implementations

impl<T: Clone + Send + 'static> EventBus<T>

pub fn new(capacity: usize) -> Self

New bus with the given buffer capacity. Higher = more tolerance for slow consumers; lower = less memory pressure under heavy fan-out. Capacity floors at 1.

pub fn send(&self, event: T) -> usize

Send a message to every active subscriber. Returns the number of subscribers who received it (zero is fine — no-op when no clients are connected).

pub fn receiver_count(&self) -> usize

Number of currently active subscribers.

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

Subscribe to the bus. Drop the receiver to disconnect.

Trait Implementations

impl<T: Clone + Send + 'static> Clone for EventBus<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.