dfir_rs 0.16.0

fn main() {
    let (_send, recv) = dfir_rs::util::unbounded_channel::<i32>();
    let mut flow = dfir_rs::dfir_syntax! {
        x = source_stream(recv);
        loop {
            x -> batch() -> for_each(|_x: i32| {});
        };
    };
}