close stream before releasing lock (#254)

* close stream before releasing lock

* Close stream before releasing lock

Author: deathbyknowledge

.changeset/twenty-doors-learn.md

@@ -0,0 +1,5 @@
+---
+"@cloudflare/sandbox": patch
+---
+
+close stream before releasing lock

packages/sandbox/src/clients/interpreter-client.ts

@@ -267,6 +267,12 @@ export class InterpreterClient extends BaseHttpClient {
         yield buffer;
       }
     } finally {
+      // Cancel the stream first to properly terminate HTTP connections when breaking early
+      try {
+        await reader.cancel();
+      } catch {
+        // Ignore cancel errors (stream may already be closed)
+      }
       reader.releaseLock();
     }
   }

packages/sandbox/src/file-stream.ts

@@ -37,6 +37,12 @@ async function* parseSSE(
       }
     }
   } finally {
+    // Cancel the stream first to properly terminate HTTP connections when breaking early
+    try {
+      await reader.cancel();
+    } catch {
+      // Ignore cancel errors (stream may already be closed)
+    }
     reader.releaseLock();
   }
 }

packages/sandbox/src/sse-parser.ts

@@ -72,6 +72,9 @@ export async function* parseSSEStream<T>(
     }
   } finally {
     // Clean up resources
+    try {
+      await reader.cancel();
+    } catch {}
     reader.releaseLock();
   }
 }