Struct EventEmitter 

pub struct EventEmitter { /* private fields */ }

A thread-safe, typed event emitter for pub/sub messaging.

Example

use hypen_server::events::EventEmitter;
use serde_json::json;
use std::sync::{Arc, Mutex};

let emitter = EventEmitter::new();

let received = Arc::new(Mutex::new(Vec::new()));
let received_clone = received.clone();

let _sub = emitter.on("user:login", move |payload| {
    received_clone.lock().unwrap().push(payload.clone());
});

emitter.emit("user:login", &json!({"name": "Alice"}));

assert_eq!(received.lock().unwrap().len(), 1);

Implementations

impl EventEmitter

pub fn new() -> Self

pub fn on<F>(&self, event: impl Into<String>, handler: F) -> SubscriptionId

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

Subscribe to an event. Returns a SubscriptionId for unsubscribing.

pub fn once<F>(&self, event: impl Into<String>, handler: F) -> SubscriptionId

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

Subscribe to an event once. The handler is removed after the first call.

pub fn emit(&self, event: &str, payload: &Value)

Emit an event to all listeners.

pub fn off(&self, id: SubscriptionId)

Unsubscribe a specific listener by its SubscriptionId.

pub fn remove_all(&self, event: &str)

Remove all listeners for a specific event.

pub fn clear(&self)

Clear all listeners for all events.

pub fn listener_count(&self, event: &str) -> usize

Get the number of listeners for an event.

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

Get all event names that have at least one listener.

Trait Implementations

impl Default for EventEmitter

fn default() -> Self

Returns the “default value” for a type.