diff options
Diffstat (limited to 'src/worker.rs')
| -rw-r--r-- | src/worker.rs | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/src/worker.rs b/src/worker.rs index daec64e..90c9e93 100644 --- a/src/worker.rs +++ b/src/worker.rs @@ -103,12 +103,7 @@ impl<S: UdpSender, R: UdpReceiver> Worker<S, R> { let timeout = Duration::from_secs(TIMEOUT); for chan in self.chans.iter_mut() { - chan.splits = chan - .splits - .drain_filter( - |_k, v| !matches!(v.timestamp, Some(t) if t.elapsed() < timeout), - ) - .collect(); + chan.splits.retain(|_, v| !matches!(v.timestamp, Some(t) if t.elapsed() < timeout)); } }, _ = self.resend.tick() => { |