aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2022-09-13 12:28:01 +0200
committerAlex Auvolat <alex@adnab.me>2022-09-13 12:28:01 +0200
commitb509e6057f850971e3339404cfd2240193871402 (patch)
treef300bab85b081f86e5da11418cc105bb2ad9f9ad
parentc00676feba3819883b2888799d5f743c4ca9bca0 (diff)
downloadnetapp-b509e6057f850971e3339404cfd2240193871402.tar.gz
netapp-b509e6057f850971e3339404cfd2240193871402.zip
Missing cleanup
-rw-r--r--src/send.rs1
1 files changed, 1 insertions, 0 deletions
diff --git a/src/send.rs b/src/send.rs
index af5f00c..4e16179 100644
--- a/src/send.rs
+++ b/src/send.rs
@@ -84,6 +84,7 @@ impl SendQueue {
for (_, prioq) in self.items.iter_mut() {
prioq.remove(id);
}
+ self.items.retain(|(_prio, q)| !q.is_empty());
}
fn is_empty(&self) -> bool {
self.items.iter().all(|(_k, v)| v.is_empty())