Struct EventBus 

pub struct EventBus { /* private fields */ }

The main event bus for publish-subscribe communication.

Implementations

impl EventBus

pub fn new(config: EventBusConfig) -> Self

Create a new event bus with the given configuration.

pub fn publisher(&self) -> EventPublisher

Create a new publisher for this bus.

pub fn subscribe(&self, filter: EventFilter) -> EventSubscriber

Subscribe to events matching the given filter.

pub fn history(&self, filter: &EventFilter) -> Vec<Event>

Get historical events matching the given filter.

pub fn clear_history(&self)

Clear all event history.

pub fn publish(&self, event: Event)

Publish an event directly.

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.

impl Default for EventBus

fn default() -> Self

Returns the “default value” for a type.