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

pub trait Replay<T: Timestamp, D: Data> {
    fn replay_into<S: Scope<Timestamp = T>>(self, scope: &mut S) -> Stream<S, D>;
}

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

Required Methods

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

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

Implementors

• impl<T: Timestamp, D: Data, I> Replay<T, D> for I where
    I: IntoIterator,
    <I as IntoIterator>::Item: EventIterator<T, D> + 'static,