From f0a1b8e1e16dfdb03b94ce55b1c94da540cb8285 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= Date: Wed, 23 Mar 2022 21:38:30 +0100 Subject: [PATCH] ws: rewrite connection cleaning retain fn --- aquatic_ws/src/workers/socket.rs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/aquatic_ws/src/workers/socket.rs b/aquatic_ws/src/workers/socket.rs index 9f0384c..4557f78 100644 --- a/aquatic_ws/src/workers/socket.rs +++ b/aquatic_ws/src/workers/socket.rs @@ -156,15 +156,15 @@ async fn clean_connections( let now = Instant::now(); connection_slab.borrow_mut().retain(|_, reference| { - let keep = reference.valid_until.0 > now; - - if !keep { + if reference.valid_until.0 > now { + true + } else { if let Some(ref handle) = reference.task_handle { handle.cancel(); } - } - keep + false + } }); connection_slab.borrow_mut().shrink_to_fit();