diff options
| author | Alex Auvolat <alex@adnab.me> | 2022-09-13 12:28:01 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2022-09-13 12:28:01 +0200 |
| commit | b509e6057f850971e3339404cfd2240193871402 (patch) | |
| tree | f300bab85b081f86e5da11418cc105bb2ad9f9ad | |
| parent | c00676feba3819883b2888799d5f743c4ca9bca0 (diff) | |
| download | netapp-b509e6057f850971e3339404cfd2240193871402.tar.gz netapp-b509e6057f850971e3339404cfd2240193871402.zip | |
Missing cleanup
| -rw-r--r-- | src/send.rs | 1 |
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()) |