registry-io 0.4.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
35
36
37
38

//! Basic `SyncRegistry` usage: register, notify, unregister.
//!
//! Run with: `cargo run --example basic`

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

use registry_io::SyncRegistry;

#[derive(Debug)]
struct Tick(u32);

fn main() {
    let registry: SyncRegistry<Tick> = SyncRegistry::new();
    let counter = Arc::new(AtomicU32::new(0));

    let sink = Arc::clone(&counter);
    let id_add = registry.register(move |tick| {
        let _ = sink.fetch_add(tick.0, Ordering::Relaxed);
    });

    let _ = registry.register(|tick: &Tick| {
        println!("observed tick: {}", tick.0);
    });

    registry.notify(&Tick(2));
    registry.notify(&Tick(3));

    println!("total accumulated: {}", counter.load(Ordering::Relaxed));

    assert!(registry.unregister(id_add));
    registry.notify(&Tick(100));

    println!(
        "after unregistering the accumulator, total stayed at: {}",
        counter.load(Ordering::Relaxed)
    );
}