···

       
73
       
73
       
 
       
    pub async fn next(&self) -> Option<T> {

     

       
74
       
74
       
 
       
        let get = || async {

     

       
75
       
75
       
 
       
            let mut q = self.q.lock().await;

     

       
76
       
76
       
+
       
            metrics::gauge!("delay_queue_queue_len").set(q.queue.len() as f64);

     

       
77
       
77
       
+
       
            metrics::gauge!("delay_queue_queue_capacity").set(q.queue.capacity() as f64);

     

       
76
       
78
       
 
       
            while let Some((t, k)) = q.queue.pop_front() {

     

       
77
       
79
       
 
       
                // skip over queued keys that were removed from items

     

       
78
       
80
       
 
       
                if let Some(item) = q.items.remove(&k) {