use dfir_rs::dfir_syntax;
pub fn main() {
let mut flow = dfir_syntax! {
source_iter(0..10)
-> filter_map(|n| {
let n2 = n * n;
if n2 > 10 {
Some(n2)
}
else {
None
}
})
-> flat_map(|n| n..=n+1)
-> for_each(|n| println!("G'day {}", n));
};
flow.run_available_sync();
}