Skip to main content

may_resend

Function may_resend 

Source
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.