Struct EventBus 

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

Generic broadcast-based event bus.

Wraps tokio::sync::broadcast for type-safe pub/sub event distribution. Any number of subscribers can consume events concurrently.

Implementations

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

pub fn new(capacity: usize) -> Self

Create a new event bus with the given broadcast channel capacity.

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

Subscribe to events. Returns a receiver that will receive all events published after this call.

pub fn publish(&self, event: E) -> Result<()>

Publish an event to all subscribers.

Returns Ok(()) even if there are zero subscribers. Returns an error only if all receivers have been dropped.

pub fn subscriber_count(&self) -> usize

Returns the number of active subscribers.

Trait Implementations

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

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E: Clone + Send + 'static> Debug for EventBus<E>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.