[−][src]Trait timely::dataflow::operators::concat::Concatenate
Merge the contents of multiple streams.
Required methods
fn concatenate<I>(&self, sources: I) -> Stream<G, D> where
I: IntoIterator<Item = Stream<G, D>>,
I: IntoIterator<Item = 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)); });
Implementors
impl<G: Scope, D: Data> Concatenate<G, D> for Stream<G, D>
[src]
fn concatenate<I>(&self, sources: I) -> Stream<G, D> where
I: IntoIterator<Item = Stream<G, D>>,
[src]
I: IntoIterator<Item = Stream<G, D>>,
impl<G: Scope, D: Data> Concatenate<G, D> for G
[src]
fn concatenate<I>(&self, sources: I) -> Stream<G, D> where
I: IntoIterator<Item = Stream<G, D>>,
[src]
I: IntoIterator<Item = Stream<G, D>>,