rs_events 0.1.0

A flexible and ergonomic event emission crate for Rust. Supports both std/threaded and no_std/alloc environments, with tagging, listener lifetimes, async/sync emission, and robust error handling.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

//! Example: Threaded event-driven server (std)
use rs_events::{EventEmitter, EventHandler};
use std::sync::Arc;

fn main() {
    let mut emitter = EventEmitter::<String>::default();
    emitter
        .add(
            "client_connected",
            None,
            Arc::new(|payload| {
                println!("Client connected: {}", payload.as_ref());
            }),
        )
        .unwrap();
    emitter
        .add(
            "message_received",
            None,
            Arc::new(|payload| {
                println!("Message: {}", payload.as_ref());
            }),
        )
        .unwrap();

    // Simulate server events
    emitter
        .emit("client_connected", Arc::new("Alice".to_string()))
        .unwrap();
    emitter
        .emit("message_received", Arc::new("Hello from Alice".to_string()))
        .unwrap();
}