diff --git a/NucleicRemote/NucleicRemote/Models/RemoteStore.swift b/NucleicRemote/NucleicRemote/Models/RemoteStore.swift
index 16cb7fa..7cd57f1 100644
--- a/NucleicRemote/NucleicRemote/Models/RemoteStore.swift
+++ b/NucleicRemote/NucleicRemote/Models/RemoteStore.swift
@@ -793,6 +793,8 @@ final class RemoteStore: ObservableObject {
         Task { [weak self] in
             let cached = await SessionCache.loadEvents(sessionID)
             guard let self, self.openSessionID == sessionID, !cached.isEmpty else { return }
+            // Drain any live deltas first so the seq-dedup merge sees the complete stream.
+            self.drainPendingOpenEvents()
             self.openEvents = Self.mergedEvents(cached, self.openEvents)
         }
     }