Build a [`health_router`] that has already observed its first probe outcome. Test-only — production code must not block the listener on the first poll (see [`health_router`]).
(store: Arc<Store>)
| 439 | /// outcome. Test-only — production code must not block the listener on |
| 440 | /// the first poll (see [`health_router`]). |
| 441 | async fn polled_health_router(store: Arc<Store>) -> Router { |
| 442 | let mut monitor = DatabaseHealthMonitor::spawn(store); |
| 443 | monitor.wait_until_polled().await; |
| 444 | health_router_from_receiver(monitor.subscribe()) |
| 445 | } |
| 446 | |
| 447 | async fn get(router: Router, path: &str) -> (StatusCode, serde_json::Value) { |
| 448 | let response = router |
no test coverage detected