Trait timely::dataflow::operators::to_stream::ToStreamCore

pub trait ToStreamCore<T: Timestamp, C: Container> {
    // Required method
    fn to_stream_core<S: Scope<Timestamp = T>>(
        self,
        scope: &mut S
    ) -> StreamCore<S, C>;
}

Converts to a timely StreamCore.

Required Methods

fn to_stream_core<S: Scope<Timestamp = T>>( self, scope: &mut S ) -> StreamCore<S, C>

Converts to a timely StreamCore.

Examples

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

let (data1, data2) = timely::example(|scope| {
    let data1 = Some((0..3).collect::<Vec<_>>()).to_stream_core(scope).capture();
    let data2 = Some(vec![0,1,2]).to_stream_core(scope).capture();
    (data1, data2)
});

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

Object Safety

This trait is not object safe.

Implementors

impl<T: Timestamp, I: IntoIterator + 'static> ToStreamCore<T, <I as IntoIterator>::Item> for I

where I::Item: Container,