()
| 586 | |
| 587 | #[tokio::test] |
| 588 | async fn test_metrics_snapshot() { |
| 589 | let (tx, _) = broadcast::channel(100); |
| 590 | let cfg = SessionQueueConfig { |
| 591 | enable_metrics: true, |
| 592 | ..Default::default() |
| 593 | }; |
| 594 | let q = SessionLaneQueue::new("s", cfg, tx).await.unwrap(); |
| 595 | q.start().await.unwrap(); |
| 596 | assert!(q.metrics_snapshot().await.is_some()); |
| 597 | } |
| 598 | |
| 599 | #[tokio::test] |
| 600 | async fn test_pending_external_tasks_empty() { |