Trait timely::dataflow::operators::core::concat::Concatenate

source ·
pub trait Concatenate<G: Scope, C: Container> {
    // Required method
    fn concatenate<I>(&self, sources: I) -> StreamCore<G, C>
       where I: IntoIterator<Item = StreamCore<G, C>>;
}
Expand description

Merge the contents of multiple streams.

Required Methods§

source

fn concatenate<I>(&self, sources: I) -> StreamCore<G, C>
where I: IntoIterator<Item = StreamCore<G, C>>,

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));
});

Object Safety§

This trait is not object safe.

Implementors§

source§

impl<G: Scope, C: Container> Concatenate<G, C> for StreamCore<G, C>

source§

impl<G: Scope, C: Container> Concatenate<G, C> for G