feat(stream): immediately exit send loop when scope is disposed

justmoon · Oct 26, 2024 · c1e4d79 · c1e4d79
1 parent b7aaabb
commit c1e4d79
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/.changeset/chilly-jars-drop.md b/.changeset/chilly-jars-drop.md
@@ -0,0 +1,5 @@
+---
+"@dassie/lib-protocol-stream": patch
+---
+
+Immediately stop sending when scope is disposed
diff --git a/packages/lib-protocol-stream/src/connection/send-until-done.ts b/packages/lib-protocol-stream/src/connection/send-until-done.ts
@@ -14,7 +14,7 @@ export function sendUntilDone(state: ConnectionState) {
 
   state.sendLoopPromise = (async function sendLoop() {
     for (;;) {
-      const hasWork = hasWorkToDo(state)
+      const hasWork = !state.scope.isDisposed && hasWorkToDo(state)
 
       // If we have no more new work to do and no work is in progress, that
       // means we are fully done and can end the loop.