Skip to main content

remove_worker_if_same_channel

Function remove_worker_if_same_channel 

Source
fn remove_worker_if_same_channel(
    workers: &DashMap<BatchKey, PendingWorker>,
    key: &BatchKey,
    worker_tx: &Sender<WorkerCommand>,
) -> bool