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

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

Merge the contents of multiple streams.

Required Methods

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

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

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