Struct EventBus 

pub struct EventBus { /* private fields */ }

Event bus for component communication

Provides publish-subscribe messaging between components with event routing, subscription management, and event queuing for asynchronous processing.

Implementations

impl EventBus

pub fn new() -> Self

Create a new event bus

pub fn subscribe( &mut self, event_type: &str, component_id: &str, ) -> SklResult<()>

Subscribe a component to an event type

pub fn unsubscribe( &mut self, event_type: &str, component_id: &str, ) -> SklResult<()>

Unsubscribe a component from an event type

pub fn publish(&mut self, event: ComponentEvent) -> SklResult<()>

Publish an event to the bus

pub fn emit_event(&mut self, event: ComponentEvent) -> SklResult<()>

Emit an event (alias for publish for backward compatibility)

pub fn process_events(&mut self) -> SklResult<Vec<EventProcessingResult>>

Process all queued events

pub fn register_handler( &mut self, event_type: &str, handler: Box<dyn EventHandler>, )

Register an event handler

pub fn get_statistics(&self) -> &EventStatistics

Get event statistics

pub fn get_subscribers(&self, event_type: &str) -> Vec<String>

Get subscribers for an event type

pub fn clear_queue(&mut self)

Clear all events from the queue

pub fn queue_size(&self) -> usize

Get current queue size

pub fn configure_routing(&mut self, config: EventRoutingConfig)

Configure event routing

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.