Skip to main content

capture_send/
capture_send.rs

1use std::net::TcpStream;
2use timely::dataflow::operators::ToStream;
3use timely::dataflow::operators::capture::{Capture, EventWriter};
4
5fn main() {
6    timely::execute_from_args(std::env::args(), |worker| {
7
8        let addr = format!("127.0.0.1:{}", 8000 + worker.index());
9        let send = TcpStream::connect(addr).unwrap();
10
11        worker.dataflow::<u64,_,_>(|scope|
12            (0..10u64)
13                .to_stream(scope)
14                .container::<Vec<_>>()
15                .capture_into(EventWriter::new(send))
16        );
17    }).unwrap();
18}