Trait Concat 

pub trait Concat {
    // Required method
    fn concat(self, other: Self) -> Self;
}

Merge the contents of two streams.

Required Methods

fn concat(self, other: Self) -> Self

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.clone()
          .concat(stream)
          .container::<Vec<_>>()
          .inspect(|x| println!("seen: {:?}", x));
});

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<'scope, T: Timestamp, C: Container> Concat for Stream<'scope, T, C>