Transcript Incremental Projection

Nucleic-Session: 0FFD007B-0696-4517-9429-129C7B0FD5AC Co-authored-by: Nucleic <[email protected]>
2026-07-06 19:44:01 -07:00
parent 0a236f447b
commit e8d5133adb
1 changed files with 3 additions and 0 deletions
@@ -872,6 +872,9 @@ final class HostConnection {
        eventTask?.cancel(); eventTask = nil
        if let client { Task { await client.disconnect() } }
        client = nil
+        // A dropped connection loses the in-flight prefetch's remaining chunks — settle it empty
+        // so RemoteStore's queue isn't left waiting on a completion that will never arrive.
+        finishPrefetch(delivering: false)
    }
 }