(&self)
| 211 | } |
| 212 | |
| 213 | pub async fn keys(&self) -> Vec<String> { |
| 214 | let inner = self.inner.read().await; |
| 215 | inner.keys().cloned().collect() |
| 216 | } |
| 217 | |
| 218 | pub async fn queue_depth(&self, function_name: &str) -> usize { |
| 219 | let inner = self.inner.read().await; |
no test coverage detected