Struct EventBus

pub struct EventBus { /* private fields */ }

Event bus for managing event distribution

Implementations

impl EventBus

pub fn new() -> Self

Create a new event bus

pub fn with_config(max_queue_size: usize, tracing_enabled: bool) -> Self

Create a new event bus with custom configuration

pub async fn subscribe<E: Event, H: EventHandler<E> + 'static>( &self, handler: H, ) -> Result<()>

Subscribe to events of a specific type

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

Publish an event to all subscribers

pub async fn create_stream<E: Event>( &self, ) -> Receiver<Arc<dyn Any + Send + Sync>>

Create a broadcast channel for streaming events

pub async fn clear(&self)

Unsubscribe from all events (clears all handlers)

pub async fn handler_count<E: Event>(&self) -> usize

Get the number of handlers for a specific event type

Trait Implementations

impl Default for EventBus

fn default() -> Self

Returns the “default value” for a type.