Trait timely::dataflow::operators::concat::Concat [−][src]
Merge the contents of two streams.
Required methods
fn concat(&self, _: &Stream<G, D>) -> Stream<G, D>
[src]
Merge the contents of two streams.
Examples
use timely::dataflow::operators::{ToStream, Concat, Inspect}; timely::example(|scope| { let stream = (0..10).to_stream(scope); stream.concat(&stream) .inspect(|x| println!("seen: {:?}", x)); });