registry-io 0.9.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

//! Basic `AsyncRegistry` usage: register an async handler, notify, observe.
//!
//! Run with: `cargo run --example async_basic --features async`

use std::sync::Arc;
use std::sync::atomic::{AtomicU64, Ordering};

use registry_io::r#async::AsyncRegistry;

#[tokio::main(flavor = "current_thread")]
async fn main() {
    let registry: AsyncRegistry<u64> = AsyncRegistry::new();
    let total = Arc::new(AtomicU64::new(0));

    for label in ["alpha", "beta", "gamma"] {
        let sink = Arc::clone(&total);
        let _ = registry.register(move |value| {
            let sink = Arc::clone(&sink);
            let v = *value;
            async move {
                // Pretend this is real async work — a tokio::time::sleep, a
                // database write, an HTTP call. The registry doesn't care.
                tokio::task::yield_now().await;
                let _ = sink.fetch_add(v, Ordering::Relaxed);
                println!("[{label}] saw {v}");
            }
        });
    }

    registry.notify(&7).await;
    println!("total: {}", total.load(Ordering::Relaxed));
}