Skip to main content

drain_batch

servers::batcher::table::pending_worker

Function drain_batch 

Source 
fn drain_batch(
    pending: &mut PendingWorker<PendingBatch, TimingFlushPolicy>,
    trigger: Option<FlushTrigger>,
) -> Option<Batch>