Function render_source_stream

fn render_source_stream<G, FromTime>(
    scope: &mut G,
    dataflow_debug_name: &String,
    export_id: GlobalId,
    ok_source: VecCollection<G, SourceOutput<FromTime>, Diff>,
    data_config: SourceExportDataConfig,
    description: &IngestionDescription<CollectionMetadata>,
    error_collections: &mut Vec<VecCollection<G, DataflowError, Diff>>,
    storage_state: &StorageState,
    base_source_config: &RawSourceCreationConfig,
    rehydrated_token: impl Any + 'static,
) -> (VecCollection<G, Row, Diff>, Vec<PressOnDropButton>, Vec<Stream<G, HealthStatusMessage>>)
where
    G: Scope<Timestamp = Timestamp>,
    FromTime: Timestamp + Sync,

Completes the rendering of a particular source stream by applying decoding and envelope processing as necessary