async fn may_resend<F: RegistryBatchFlow>(
ctx: &BatchFlowContext<'_>,
next: &PendingBatch<F::Extra, F::Request>,
waiting: &[PendingBatch<F::Extra, F::Request>],
) -> CreditRegistrationResult<bool>Expand description
Before a resent half: false once a shutdown is under way, since each half can take the whole
request timeout and sending the rest would outlast the termination grace period. Otherwise keeps
next and every row still waiting in flight.