Lines Matching refs:DelayQueue

7 use tokio_util::time::DelayQueue;
28 let mut queue = task::spawn(DelayQueue::new()); in single_immediate_delay()
44 let mut queue = task::spawn(DelayQueue::new()); in multi_immediate_delays()
73 let mut queue = task::spawn(DelayQueue::new()); in single_short_delay()
100 let mut queue = task::spawn(DelayQueue::new()); in multi_delay_at_start()
137 let mut queue = task::spawn(DelayQueue::new()); in insert_in_past_fires_immediately()
151 let mut queue = task::spawn(DelayQueue::new()); in remove_entry()
170 let mut queue = task::spawn(DelayQueue::new()); in reset_entry()
204 let mut queue = task::spawn(DelayQueue::new()); in reset_much_later()
226 let mut queue = task::spawn(DelayQueue::new()); in reset_twice()
256 let mut queue = task::spawn(DelayQueue::new()); in repeatedly_reset_entry_inserted_as_expired()
281 let mut queue = DelayQueue::new(); in remove_expired_item()
301 let mut queue = task::spawn(DelayQueue::new()); in remove_at_timer_wheel_threshold()
329 let mut queue = task::spawn(DelayQueue::new()); in expires_before_last_insert()
355 let mut queue = task::spawn(DelayQueue::new()); in multi_reset()
392 let mut queue = task::spawn(DelayQueue::new()); in expire_first_key_when_reset_to_expire_earlier()
415 let mut queue = task::spawn(DelayQueue::new()); in expire_second_key_when_reset_to_expire_earlier()
438 let mut queue = task::spawn(DelayQueue::new()); in reset_first_expiring_item_to_expire_later()
460 let mut queue = task::spawn(DelayQueue::new()); in insert_before_first_after_poll()
486 let mut queue = task::spawn(DelayQueue::new()); in insert_after_ready_poll()
519 let mut queue = task::spawn(DelayQueue::new()); in reset_later_after_slot_starts()
555 let mut queue = task::spawn(DelayQueue::new()); in reset_inserted_expired()
577 let mut queue = task::spawn(DelayQueue::new()); in reset_earlier_after_slot_starts()
614 let mut queue = task::spawn(DelayQueue::new()); in insert_in_past_after_poll_fires_immediately()