Function mz_storage::source::source_reader_pipeline::demux_source_exports

source ยท 
fn demux_source_exports<G, FromTime>(
    config: RawSourceCreationConfig,
    input: Collection<G, (usize, Result<SourceOutput<FromTime>, DataflowError>), Diff>,
) -> Vec<(GlobalId, Collection<G, SourceOutput<FromTime>, Diff>, Collection<G, DataflowError, Diff>, SourceExportDataConfig)>
where
    G: Scope<Timestamp = Timestamp>,
    FromTime: SourceTimestamp,
Expand description

Demultiplexes a combined stream of all source exports into individual collections per source export