Searched defs:paused_queues (Results 1 – 2 of 2) sorted by relevance
887 paused_queues: Option<PausedQueues>, field921 let paused_queues = { in run_worker() localVariable1101 let mut paused_queues = PausedQueues::new( in run_worker() localVariable
1552 let paused_queues = PausedQueues::new(rx_queue, tx_queue, event_handler_queue); in run() localVariable