Struct EventBus 

pub struct EventBus { /* private fields */ }

In-process publish/subscribe event bus

Supports both synchronous and asynchronous event handlers. Multiple handlers can be registered for the same event topic.

Example

use rustapi_core::events::EventBus;

let bus = EventBus::new();

// Synchronous handler
bus.on("user.created", |payload: &str| {
    println!("User created: {}", payload);
});

// Emit events
bus.emit("user.created", "user_123");

Implementations

impl EventBus

pub fn new() -> EventBus

Create a new EventBus instance

pub fn on<F>(&self, topic: &str, handler: F)

where F: Fn(&str) + Send + Sync + 'static,

Register a synchronous event handler for a topic

The handler will be called with the event payload string whenever the topic is emitted.

Example

use rustapi_core::events::EventBus;

let bus = EventBus::new();
bus.on("order.completed", |payload: &str| {
    println!("Order completed: {}", payload);
});

pub fn on_async<F>(&self, topic: &str, handler: F)

where F: Fn(String) -> Pin<Box<dyn Future<Output = ()> + Send>> + Send + Sync + 'static,

Register an async event handler for a topic

The handler will be spawned as a tokio task when the topic is emitted.

Example

use rustapi_core::events::EventBus;

let bus = EventBus::new();
bus.on_async("email.send", |payload: String| {
    Box::pin(async move {
        send_email(&payload).await;
    })
});

pub fn emit(&self, topic: &str, payload: &str)

Emit an event synchronously

Calls all synchronous handlers for the topic in registration order. Also spawns tokio tasks for any async handlers.

Example

use rustapi_core::events::EventBus;

let bus = EventBus::new();
bus.on("log", |msg: &str| println!("{}", msg));
bus.emit("log", "Hello!");

pub async fn emit_await(&self, topic: &str, payload: &str)

Emit an event and await all async handlers

Unlike emit(), this waits for all async handlers to complete.

pub fn handler_count(&self, topic: &str) -> usize

Get the number of registered handlers for a topic (both sync and async)

pub fn topics(&self) -> Vec<String>

Get all registered topic names

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() -> EventBus

Returns the “default value” for a type.