pub trait ComputeReplay {
    fn replay<G: Scope<Timestamp = Timestamp>>(
        &mut self,
        scope: &mut G,
        name: &str,
        request: SourceInstanceRequest
    ) -> (Collection<G, Row, Diff>, Collection<G, DataflowError, Diff>, Rc<dyn Any>); }
Expand description

A type that can replay specific sources

Required methods

Replays the source bound to id.

None is returned if the source does not exist, either because it was not there to begin, or has already been replayed. Either case is likely an error.

Implementations on Foreign Types