Lines Matching defs:DelayQueue
132 pub struct DelayQueue<T> { struct
134 slab: SlabStorage<T>,
137 wheel: Wheel<Stack<T>>,
141 expired: Stack<T>,
144 delay: Option<Pin<Box<Sleep>>>,
147 wheel_now: u64,
150 start: Instant,
155 waker: Option<Waker>,
434 impl<T> DelayQueue<T> { impl
1109 impl<T> Unpin for DelayQueue<T> {} implementation
1111 impl<T> Default for DelayQueue<T> { implementation
1117 impl<T> futures_core::Stream for DelayQueue<T> { implementation