diff options
| author | Lizzy Fleckenstein <eliasfleckenstein@web.de> | 2023-02-26 03:05:53 +0100 |
|---|---|---|
| committer | Lizzy Fleckenstein <eliasfleckenstein@web.de> | 2023-02-26 03:05:53 +0100 |
| commit | d016a6359a4ad469e2ed295f11b6ec7a3d2bcb4b (patch) | |
| tree | d9e862d3b7d3239d1982798c0d0bdef41492b76d /src/worker.rs | |
| parent | a4c3c05c69a4f9de76e41980594d180ec9ffe03b (diff) | |
| download | mt_rudp-d016a6359a4ad469e2ed295f11b6ec7a3d2bcb4b.tar.xz | |
Use HashMap::retain
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() => { |