Transcript Incremental Projection
Nucleic-Session: 0FFD007B-0696-4517-9429-129C7B0FD5AC Co-authored-by: Nucleic <[email protected]>
This commit is contained in:
@@ -793,6 +793,8 @@ final class RemoteStore: ObservableObject {
|
|||||||
Task { [weak self] in
|
Task { [weak self] in
|
||||||
let cached = await SessionCache.loadEvents(sessionID)
|
let cached = await SessionCache.loadEvents(sessionID)
|
||||||
guard let self, self.openSessionID == sessionID, !cached.isEmpty else { return }
|
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)
|
self.openEvents = Self.mergedEvents(cached, self.openEvents)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user