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
/// Reference an operator that doesn't have singleton state.
pub fn main() {
    let mut df = hydroflow::hydroflow_syntax! {
        my_ref = source_iter(15..=25) -> null();
        source_iter(10..=30)
            -> persist::<'static>()
            -> filter(|value| value <= #my_ref.as_reveal_ref())
            -> null();

    };
    df.run_available();
}