Function mz_compute::render::flat_map::drain_through_mfp

fn drain_through_mfp<T>(
    input_row: &Row,
    input_time: &T,
    input_diff: &Diff,
    datum_vec: &mut DatumVec,
    extensions: &[(Row, Diff)],
    mfp_plan: &MfpPlan,
    until: &Antichain<Timestamp>,
    ok_output: &mut Session<'_, T, ConsolidatingContainerBuilder<Vec<(Row, T, Diff)>>, Counter<T, Vec<(Row, T, Diff)>, Tee<T, Vec<(Row, T, Diff)>>>>,
    err_output: &mut Session<'_, T, ConsolidatingContainerBuilder<Vec<(DataflowError, T, Diff)>>, Counter<T, Vec<(DataflowError, T, Diff)>, Tee<T, Vec<(DataflowError, T, Diff)>>>>,
)
where
    T: RenderTimestamp,

Drains a list of extensions to input_row through a supplied MfpPlan and into output buffers.

The method decodes input_row, and should be amortized across non-trivial extensions.