1 2 3 4 5 6 7 8
use timely::dataflow::operators::{Inspect, vec::ToStream}; fn main() { timely::example(|scope| { (0..10).to_stream(scope) .inspect(|x| println!("seen: {:?}", x)); }); }