Function mz_storage::render::upsert::drain_staged_input

async fn drain_staged_input<S, G, T, O, E>(
    stash: &mut Vec<(T, UpsertKey, Reverse<O>, Option<Result<Row, UpsertError>>)>,
    commands_state: &mut IndexMap<UpsertKey, UpsertValueAndSize>,
    output_updates: &mut Vec<(Result<Row, UpsertError>, T, Diff)>,
    multi_get_scratch: &mut Vec<UpsertKey>,
    upper: &Antichain<T>,
    error_emitter: &mut E,
    state: &mut UpsertState<'_, S>
)where
    S: UpsertStateBackend,
    G: Scope,
    T: PartialOrder + Ord + Clone,
    O: Ord,
    E: UpsertErrorEmitter<G>,

Helper method for upsert_inner used to stage data updates from the input timely edge.