pub trait ToStreamCore<T: Timestamp, C: Container> {
// Required method
fn to_stream_core<S: Scope<Timestamp = T>>(
self,
scope: &mut S
) -> StreamCore<S, C>;
}
Expand description
Converts to a timely StreamCore.
Required Methods§
sourcefn to_stream_core<S: Scope<Timestamp = T>>(
self,
scope: &mut S
) -> StreamCore<S, C>
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.