Skip to main content

drain_batch

Function drain_batch 

Source
pub(super) fn drain_batch(
    batch: &mut Option<PendingBatch>,
    pending_flush: &mut PendingWorker<FlushWaiter, TimingFlushPolicy>,
    trigger: Option<FlushTrigger>,
) -> Option<Batch>
Expand description

Transfers the ready batch, or drains unconditionally when no trigger is given. Execution and flush permits remain owned by the caller.