1 2 3 4 5 6 7 8 9 10
fn main() { let mut df = dfir_rs::dfir_syntax! { a = source_iter(0..10); loop { b = a -> batch(); }; b -> null(); }; df.run_available_sync(); }