Searched refs:queue_handler (Results 1 – 2 of 2) sorted by relevance
731 let queue_handler = handle_queue( in run_worker() localVariable739 pin_mut!(queue_handler); in run_worker()742 _ = queue_handler => anyhow::bail!("queue handler exited unexpectedly"), in run_worker()
590 queue_handler = QueueHandler(que)594 root.addHandler(queue_handler)