Struct EventBus 

pub struct EventBus { /* private fields */ }

Event bus that can emit events and register event handlers

The event bus is responsible for managing event handlers and emitting events to them. It provides a simple way to register and unregister handlers, and to emit events to all registered handlers.

Examples

struct MyHandler;

#[async_trait]
impl EventHandler for MyHandler {
    async fn handle_event(&self, event: &Event) -> Result<(), Error> {
        // Handle the event...
        Ok(())
    }
}

let mut event_bus = EventBus::default();
event_bus.register(Arc::new(MyHandler));
event_bus.emit(&Event::UserCreated(User::builder().id(UserId::new("test")).build().unwrap())).await;

Implementations

impl EventBus

pub fn new() -> Self

Create a new event bus

Examples

let event_bus = EventBus::new();

pub async fn register(&self, handler: Arc<dyn EventHandler>)

Register an event handler with the event bus

Examples

struct MyHandler;

#[async_trait]
impl EventHandler for MyHandler {
    async fn handle_event(&self, event: &Event) -> Result<(), Error> {
        // Handle the event...
        Ok(())
    }
}

let mut event_bus = EventBus::default();
event_bus.register(Arc::new(MyHandler));

pub async fn emit(&self, event: &Event) -> Result<(), EventError>

Emit an event to all registered handlers

Examples

let event_bus = EventBus::default();
event_bus.emit(&Event::UserCreated(User::builder().id(UserId::new("test")).build().unwrap())).await;

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.