Get queue size
(&self)
| 217 | |
| 218 | /// Get queue size |
| 219 | pub async fn len(&self) -> usize { |
| 220 | self.queue.lock().await.len() |
| 221 | } |
| 222 | |
| 223 | /// Check if the queue is empty |
| 224 | pub async fn is_empty(&self) -> bool { |
no outgoing calls
no test coverage detected