Searched refs:queue_task (Results 1 – 5 of 5) sorted by relevance
170 let _ = self.ex.run_until(worker.queue_task.cancel()); in reset()198 let queue_task = match idx { in start_queue() localVariable241 let queue_task = self.ex.spawn_local(async move { in start_queue() localVariable252 queue_task: response_queue_task, in start_queue()256 Some(queue_task) in start_queue()265 if let Some(queue_task) = queue_task { in start_queue()266 self.workers[idx] = Some(WorkerState { queue_task, queue }); in start_queue()278 let _ = self.ex.run_until(worker.queue_task.cancel()); in stop_queue()289 let _ = self.ex.run_until(worker.queue_task.cancel()); in stop_queue()
224 let queue_task = match idx { in start_queue() localVariable243 self.workers[idx] = Some(WorkerState { queue_task, queue }); in start_queue()250 let _ = self.ex.run_until(worker.queue_task.cancel()); in stop_queue()265 let _ = self.ex.run_until(worker.queue_task.cancel()); in reset()
157 let queue_task = match idx { in start_queue() localVariable214 self.queue_workers[idx] = Some(WorkerState { queue_task, queue }); in start_queue()221 let _ = self.ex.run_until(worker.queue_task.cancel()); in stop_queue()
955 pub(crate) queue_task: TaskHandle<U>, field
122 self.queue_task = None127 self.queue_task = asyncio.create_task(self.process_queue())187 if self.queue_task:188 self.queue_task.cancel()