timely 0.29.0

A low-latency data-parallel dataflow system in Rust
Documentation
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));
    });
}