timely 0.2.0

A low-latency data-parallel dataflow system in Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

extern crate timely;

use std::net::TcpStream;
use timely::dataflow::operators::{Capture, ToStream};
use timely::dataflow::operators::capture::EventWriter;

fn main() {
    timely::execute(timely::Configuration::Thread, |worker| {
        let send = TcpStream::connect("127.0.0.1:8000").unwrap();

        worker.dataflow::<u64,_,_>(|scope|
            (0..10u64)
                .to_stream(scope)
                .capture_into(EventWriter::new(send))
        );
    }).unwrap();
}