From 82bd0c8e153ba5eae6068842491b60cee6d8ae99 Mon Sep 17 00:00:00 2001
From: timedout <git@nexy7574.co.uk>
Date: Fri, 27 Feb 2026 11:18:43 +0000
Subject: [PATCH] fix: Actually flush destinations before selecting new events

---
 src/service/sending/sender.rs | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/service/sending/sender.rs b/src/service/sending/sender.rs
index 0426a510..2c51636e 100644
--- a/src/service/sending/sender.rs
+++ b/src/service/sending/sender.rs
@@ -203,6 +203,9 @@ impl Service {
 		futures: &mut SendingFutures<'a>,
 		statuses: &mut CurTransactionStatus,
 	) {
+		if msg.event == SendingEvent::Flush {
+			statuses.remove(&msg.dest);
+		}
 		let iv = vec![(msg.queue_id, msg.event)];
 		if let Ok(Some(events)) = self.select_events(&msg.dest, iv, statuses).await {
 			if !events.is_empty() {