Skip to main content

spawn_flush

servers::batcher::table::pending_worker

Function spawn_flush 

Source 
async fn spawn_flush(
    batch: Batch,
    limiter: &FlushLimiter,
    inserter: Arc<Inserter>,
    notifier: FlowNotifier,
) -> Option<JoinHandle<()>>