Trait timely::dataflow::operators::concat::Concatenate
[−]
[src]
pub trait Concatenate<G: Scope, D: Data> { fn concatenate(&self, Vec<Stream<G, D>>) -> Stream<G, D>; }
Merge the contents of multiple streams.
Required Methods
fn concatenate(&self, Vec<Stream<G, D>>) -> Stream<G, D>
Merge the contents of multiple streams.
Examples
use timely::dataflow::operators::{ToStream, Concatenate, Inspect}; timely::example(|scope| { let streams = vec![(0..10).to_stream(scope), (0..10).to_stream(scope), (0..10).to_stream(scope)]; scope.concatenate(streams) .inspect(|x| println!("seen: {:?}", x)); });