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>
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());
Implementors
impl<T: Timestamp, I: IntoIterator + 'static> ToStream<T, I::Item> for I where
I::Item: Data,