Trait timely::dataflow::operators::core::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 StreamCore<S, C>.

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.

Provided Methods

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

Replays self into the provided scope, as a StreamCore<S, C>.

Object Safety

This trait is not object safe.

Implementors

impl<T: Timestamp, C: Container + Clone + 'static, I> Replay<T, C> for I

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