Type Alias Iterative

pub type Iterative<'a, G, T> = Child<'a, G, Product<<G as ScopeParent>::Timestamp, T>>;

Type alias for iterative child scope.

Aliased Type

pub struct Iterative<'a, G, T> {
    pub subgraph: &'a RefCell<SubgraphBuilder<<G as ScopeParent>::Timestamp, Product<<G as ScopeParent>::Timestamp, T>>>,
    pub parent: G,
    pub logging: Option<Logger<TimelyEvent, usize>>,
    pub progress_logging: Option<Logger<TimelyProgressEvent, usize>>,
}

Fields

subgraph: &'a RefCell<SubgraphBuilder<<G as ScopeParent>::Timestamp, Product<<G as ScopeParent>::Timestamp, T>>>

The subgraph under assembly.

parent: G

A copy of the child’s parent scope.

logging: Option<Logger<TimelyEvent, usize>>

The log writer for this scope.

progress_logging: Option<Logger<TimelyProgressEvent, usize>>

The progress log writer for this scope.

Trait Implementations

impl<'a, G: Scope, T: Timestamp> LoopVariable<'a, G, T> for Iterative<'a, G, T>

fn loop_variable<D: Container>( &mut self, summary: T::Summary, ) -> (HandleCore<Iterative<'a, G, T>, D>, StreamCore<Iterative<'a, G, T>, D>)

Creates a Stream and a Handle to later bind the source of that Stream.