Trait timely::dataflow::operators::enterleave::Enter[−][src]

pub trait Enter<G: Scope, T: Timestamp + Refines<G::Timestamp>, D: Data> {
    fn enter<'a>(&self, _: &Child<'a, G, T>) -> Stream<Child<'a, G, T>, D>;
}

Extension trait to move a Stream into a child of its current Scope.

Required methods

fn enter<'a>(&self, _: &Child<'a, G, T>) -> Stream<Child<'a, G, T>, D>[src]

Moves the Stream argument into a child of its current Scope.

Examples

use timely::dataflow::scopes::Scope;
use timely::dataflow::operators::{Enter, Leave, ToStream};

timely::example(|outer| {
    let stream = (0..9).to_stream(outer);
    let output = outer.region(|inner| {
        stream.enter(inner).leave()
    });
});
Loading content...

Implementors

impl<G: Scope, T: Timestamp + Refines<G::Timestamp>, D: Data> Enter<G, T, D> for Stream<G, D>[src]

Loading content...