Trait timely::dataflow::operators::to_stream::ToStream

pub trait ToStream<D: Data> {
    fn to_stream<S: Scope>(self, scope: &mut S) -> Stream<S, D>;
}

Required Methods

fn to_stream<S: Scope>(self, scope: &mut S) -> Stream<S, D>

Converts an iterator to a timely Stream, with records at the default time.

Examples

use timely::dataflow::operators::{ToStream, Inspect};

timely::example(|scope| {
    (0..10).to_stream(scope)
           .inspect(|x| println!("seen: {:?}", x));
});

Implementors

• impl<D: Data, I: Iterator<Item=D> + 'static> ToStream<D> for I