registry-io 0.5.0

High-performance event/callback registry for Rust. Sync-first with optional async. Lock-free reads, zero-allocation hot path, sub-50ns notify target. Designed as the foundation primitive for portfolio crates needing fast in-process notification.
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
34

//! Priority ordering: higher priorities fire first, ties broken by
//! registration order.
//!
//! Run with: `cargo run --example priority`

use std::sync::{Arc, Mutex};

use registry_io::SyncRegistry;

fn main() {
    let registry: SyncRegistry<&'static str> = SyncRegistry::new();
    let order: Arc<Mutex<Vec<String>>> = Arc::new(Mutex::new(Vec::new()));

    let o = Arc::clone(&order);
    let _ = registry.register_with_priority(50, move |event| {
        o.lock().unwrap().push(format!("hi-prio: {event}"));
    });

    let o = Arc::clone(&order);
    let _ = registry.register(move |event| {
        o.lock().unwrap().push(format!("default: {event}"));
    });

    let o = Arc::clone(&order);
    let _ = registry.register_with_priority(-100, move |event| {
        o.lock().unwrap().push(format!("lo-prio: {event}"));
    });

    registry.notify(&"ping");

    for line in order.lock().unwrap().iter() {
        println!("{line}");
    }
}