dfir_rs 0.16.0

DFIR runtime for Rust, used by Hydro.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

fn main() {
    let mut df = dfir_rs::dfir_syntax! {
        a = source_iter(0..10) -> tee();
        loop {
            a -> batch() -> fold::<'tick>(|| 0, |old: &mut _, val| {
                *old += val;
            }) -> for_each(|v| println!("{:?}", v));

            a -> batch() -> fold::<'static>(|| 0, |old: &mut _, val| {
                *old += val;
            }) -> for_each(|v| println!("{:?}", v));
        };
    };
    df.run_available_sync();
}