Trait timely::dataflow::operators::concat::Concat
[−]
[src]
pub trait Concat<G: Scope, D: Data> { fn concat(&self, _: &Stream<G, D>) -> Stream<G, D>; }
Merge the contents of two streams.
Required Methods
fn concat(&self, _: &Stream<G, D>) -> Stream<G, D>
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)); });