(&self)
| 54 | } |
| 55 | |
| 56 | pub(super) async fn metrics(&self) -> Option<MetricsSnapshot> { |
| 57 | match &self.session.command_queue { |
| 58 | Some(queue) => queue.metrics_snapshot().await, |
| 59 | None => None, |
| 60 | } |
| 61 | } |
| 62 | |
| 63 | pub(super) async fn dead_letters(&self) -> Vec<DeadLetter> { |
| 64 | match &self.session.command_queue { |
no test coverage detected