()
| 523 | |
| 524 | #[tokio::test] |
| 525 | async fn test_stats() { |
| 526 | let (tx, _) = broadcast::channel(100); |
| 527 | let q = SessionLaneQueue::new("s", SessionQueueConfig::default(), tx) |
| 528 | .await |
| 529 | .unwrap(); |
| 530 | q.start().await.unwrap(); |
| 531 | let stats = q.stats().await; |
| 532 | assert_eq!(stats.total_pending, 0); |
| 533 | assert_eq!(stats.total_active, 0); |
| 534 | assert_eq!(stats.external_pending, 0); |
| 535 | } |
| 536 | |
| 537 | #[tokio::test] |
| 538 | async fn test_lane_handler_config() { |