hydroflow 0.10.0

Hydro's low-level dataflow runtime and IR
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use hydroflow::hydroflow_syntax;

fn main() {
    struct Shape {
        area: f64,
    }

    let mut df = hydroflow_syntax! {
        my_demux = source_iter([
            Shape { area: 10.0 },
            Shape { area: 9.0 },
        ]) -> demux_enum::<Shape>();
        my_demux[Rectangle] -> for_each(std::mem::drop);
        my_demux[Circle] -> for_each(std::mem::drop);
        my_demux[Square] -> for_each(std::mem::drop);
        my_demux[Ellipse] -> for_each(std::mem::drop);
    };
    df.run_available();
}