async fn drain_staged_input<S, G, T, FromTime, E>(
stash: &mut Vec<(T, UpsertKey, Reverse<FromTime>, Option<Result<Row, UpsertError>>)>,
commands_state: &mut IndexMap<UpsertKey, UpsertValueAndSize<T, Option<FromTime>>>,
output_updates: &mut Vec<(Result<Row, UpsertError>, T, Diff)>,
multi_get_scratch: &mut Vec<UpsertKey>,
drain_style: DrainStyle<'_, T>,
error_emitter: &mut E,
state: &mut UpsertState<'_, S, T, Option<FromTime>>,
)where
S: UpsertStateBackend<T, Option<FromTime>>,
G: Scope,
T: PartialOrder + Ord + Clone + Send + Sync + Serialize + Debug + 'static,
FromTime: ExchangeData + Ord + Sync,
E: UpsertErrorEmitter<G>,Expand description
Helper method for upsert_inner used to stage data updates
from the input timely edge.