Struct timely::dataflow::operators::generic::OutputHandle
[−]
[src]
pub struct OutputHandle<'a, T: Timestamp, D: 'a, P: Push<(T, Content<D>)> + 'a> { /* fields omitted */ }
Handle to an operator's output stream.
Methods
impl<'a, T: Timestamp, D, P: Push<(T, Content<D>)>> OutputHandle<'a, T, D, P>
[src]
fn session<'b>(
&'b mut self,
cap: &'b Capability<T>
) -> Session<'b, T, D, PushCounter<T, D, P>> where
'a: 'b,
[src]
&'b mut self,
cap: &'b Capability<T>
) -> Session<'b, T, D, PushCounter<T, D, P>> where
'a: 'b,
Obtains a session that can send data at the timestamp associated with capability cap
.
In order to send data at a future timestamp, obtain a capability for the new timestamp first, as show in the example.
Examples
use timely::dataflow::operators::ToStream; use timely::dataflow::operators::generic::unary::Unary; use timely::dataflow::channels::pact::Pipeline; timely::example(|scope| { (0..10).to_stream(scope) .unary_stream(Pipeline, "example", |input, output| { input.for_each(|cap, data| { let mut time = cap.time().clone(); time.inner += 1; output.session(&cap.delayed(&time)).give_content(data); }); }); });