diff --git a/src/router/serve/unix.rs b/src/router/serve/unix.rs index b5938673..fb011f18 100644 --- a/src/router/serve/unix.rs +++ b/src/router/serve/unix.rs @@ -127,8 +127,8 @@ async fn fini(server: &Arc, listener: UnixListener, mut tasks: JoinSet<( debug!("Waiting for requests to finish..."); while server.metrics.requests_spawn_active.load(Ordering::Relaxed) > 0 { tokio::select! { - _ = tasks.join_next() => {} - () = sleep(FINI_POLL_INTERVAL) => {} + task = tasks.join_next() => if task.is_none() { break; }, + () = sleep(FINI_POLL_INTERVAL) => {}, } }