nexus-rt 2.0.3

Single-threaded, event-driven runtime primitives with pre-resolved dispatch
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

// Mistake: guard step takes T by value instead of &T.
// Fix: change fn(u32) -> bool to fn(&u32) -> bool.
// Guard/filter/tap/inspect pass the value through —
// the step only observes it.

use nexus_rt::{PipelineBuilder, WorldBuilder};

fn to_option(x: u32) -> Option<u32> {
    Some(x)
}

fn check_value(x: u32) -> bool {
    x > 10
}

fn main() {
    let mut wb = WorldBuilder::new();
    let world = wb.build();
    let reg = world.registry();

    // guard on Option<u32> expects fn(&u32) -> bool, not fn(u32) -> bool
    let _ = PipelineBuilder::<u32>::new()
        .then(to_option, &reg)
        .guard(check_value, &reg);
}