Trait timely::dataflow::operators::to_stream::ToStream[−][src]

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

Converts to a timely Stream.

Required methods

fn to_stream<S: Scope<Timestamp = T>>(self, scope: &mut S) -> Stream<S, D>[src]

Converts to a timely Stream.

Examples

use timely::dataflow::operators::{ToStream, Capture};
use timely::dataflow::operators::capture::Extract;

let (data1, data2) = timely::example(|scope| {
    let data1 = (0..3).to_stream(scope).capture();
    let data2 = vec![0,1,2].to_stream(scope).capture();
    (data1, data2)
});

assert_eq!(data1.extract(), data2.extract());
Loading content...

Implementors

impl<T: Timestamp, I: IntoIterator + 'static> ToStream<T, <I as IntoIterator>::Item> for I where
    I::Item: Data, [src]

Loading content...