Struct EventBus 

pub struct EventBus { /* private fields */ }

Event bus for broadcasting events to multiple listeners

Implementations

impl EventBus

pub fn new(capacity: usize) -> Self

Create a new EventBus with the specified buffer capacity

Arguments

• capacity: Maximum number of events to buffer. If this limit is exceeded and receivers are slow, the oldest events will be dropped.

Recommended values

• 100-1000 for most use cases
• Higher values if you have very slow receivers

pub fn subscribe(&self) -> EventReceiver

Subscribe to events

Returns an EventReceiver that will receive all future events emitted after this call.

pub fn emit(&self, event: Event)

Emit an event to all subscribers

If there are no active subscribers, the event is silently dropped.

Trait Implementations

impl Clone for EventBus

fn clone(&self) -> EventBus

Returns a duplicate of the value.

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

Performs copy-assignment from source.