Skip to main content

remove_worker_if_same_channel

servers::batcher::logical_table::pending_worker

Function remove_worker_if_same_channel 

Source 
pub(super) async fn remove_worker_if_same_channel(
    workers: &WorkerRegistry<BatchKey, WorkerCommand>,
    key: &BatchKey,
    worker_tx: &Sender<WorkerCommand>,
) -> bool