From 280e9a90a66b03ff640da10512165aaec2145d65 Mon Sep 17 00:00:00 2001 From: Mike Dilger Date: Tue, 20 Feb 2024 17:41:50 +1300 Subject: [PATCH] Fix runaway tokio wastage --- src/main.rs | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/main.rs b/src/main.rs index 9234d36..55abf77 100644 --- a/src/main.rs +++ b/src/main.rs @@ -343,10 +343,11 @@ impl WebSocketService { let mut last_message_at = Instant::now(); - loop { - let interval = tokio::time::interval(Duration::from_secs(5)); - tokio::pin!(interval); + let mut interval = tokio::time::interval(Duration::from_secs(5)); + let _ = interval.tick().await; // consume the first tick + tokio::pin!(interval); + loop { tokio::select! { instant = interval.tick() => { // Drop them if they have no subscriptions