Function mz_storage_client::source::persist_source::decode_and_mfp

pub fn decode_and_mfp<G, YFn>(
    fetched: &Stream<G, FetchedPart<SourceData, (), Timestamp, Diff>>,
    name: &str,
    until: Antichain<Timestamp>,
    map_filter_project: Option<&mut MfpPlan>,
    yield_fn: YFn
) -> Stream<G, (Result<Row, DataflowError>, Timestamp, Diff)>where
    G: Scope<Timestamp = Timestamp>,
    YFn: Fn(Instant, usize) -> bool + 'static,