Function dataflow::render::envelope_none::persist_and_replay

pub(crate) fn persist_and_replay<G>(
    source_name: &str, 
    stream: &Stream<G, (Result<Row, DecodeError>, Timestamp, Diff)>, 
    as_of_frontier: &Antichain<Timestamp>, 
    persist_config: PersistentEnvelopeNoneConfig<Result<Row, DecodeError>>
) -> (Stream<G, (Result<Row, DecodeError>, Timestamp, Diff)>, Stream<G, (DataflowError, Timestamp, Diff)>) where
    G: Scope<Timestamp = Timestamp>, 

Persists the given input stream, passes through the data it carries and replays previously persisted updates when starting up.

This will filter out and retract replayed updates that are not beyond the upper_seal_ts given in persist_config.