Searched refs:delay_queue (Results 1 – 3 of 3) sorted by relevance
15 pub mod delay_queue; module18 pub use delay_queue::DelayQueue;
639 let mut delay_queue = task::spawn(DelayQueue::new()); in delay_queue_poll_expired_when_empty() localVariable640 let key = delay_queue.insert(0, std::time::Duration::from_secs(10)); in delay_queue_poll_expired_when_empty()641 assert_pending!(poll!(delay_queue)); in delay_queue_poll_expired_when_empty()643 delay_queue.remove(&key); in delay_queue_poll_expired_when_empty()644 assert!(assert_ready!(poll!(delay_queue)).is_none()); in delay_queue_poll_expired_when_empty()
1953 - time: added `deadline` method to `delay_queue::Expired` ([#2300])