Struct EventBus 

pub struct EventBus { /* private fields */ }

Multi-subscriber event bus.

Events sent to this bus are broadcast to all subscribers. Uses tokio’s broadcast channel for fan-out delivery.

Implementations

impl EventBus

pub fn new() -> Self

Create a new event bus.

Spawns a background task to forward events from the mpsc channel to the broadcast channel.

pub fn with_capacity(capacity: usize) -> Self

Create a new event bus with a specific broadcast capacity.

pub fn sender(&self) -> EventSender

Get a sender for submitting events to the bus.

pub fn subscribe(&self) -> EventReceiver

Subscribe to events from this bus.

Returns a receiver that will receive all events sent to the bus after this subscription is created.

pub fn subscriber_count(&self) -> usize

Get the number of active subscribers.

Trait Implementations

impl Debug for EventBus

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

Formats the value using the given formatter.

impl Default for EventBus

fn default() -> Self

Returns the “default value” for a type.