nik/chorus
1
0
Fork 0
mirror of https://github.com/mikedilger/chorus.git synced 2026-06-02 07:02:09 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix runaway tokio wastage

Browse Source
This commit is contained in:
Mike Dilger 2024-02-20 17:41:50 +13:00
parent 254c0a9afc
commit 280e9a90a6
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main.rs
View File

@ -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