Trait timely::dataflow::operators::capture::replay::Replay

pub trait Replay<T: Timestamp, C>: Sized {
    // Required method
    fn replay_core<S: Scope<Timestamp = T>>(
        self,
        scope: &mut S,
        period: Option<Duration>
    ) -> StreamCore<S, C>;

    // Provided method
    fn replay_into<S: Scope<Timestamp = T>>(
        self,
        scope: &mut S
    ) -> StreamCore<S, C> { ... }
}

Replay a capture stream into a scope with the same timestamp.

Required Methods

fn replay_core<S: Scope<Timestamp = T>>( self, scope: &mut S, period: Option<Duration> ) -> StreamCore<S, C>

Replays self into the provided scope, as a `Stream<S, D>’.

The period argument allows the specification of a re-activation period, where the operator will re-activate itself every so often. The None argument instructs the operator not to re-activate itself.us

Provided Methods

fn replay_into<S: Scope<Timestamp = T>>(self, scope: &mut S) -> StreamCore<S, C>

Replays self into the provided scope, as a Stream<S, D>.

Object Safety

This trait is not object safe.

Implementors

impl<T: Timestamp, C: Container, I> Replay<T, C> for I

where I: IntoIterator, <I as IntoIterator>::Item: EventIteratorCore<T, C> + 'static,