Merge pull request #64 from Mupu/main

fix: #63 simple-stack-stream crash

.changeset/green-boxes-sort.md

@@ -0,0 +1,5 @@
+---
+"simple-stack-stream": patch
+---
+
+Fix unhandled crash when a connection is closed before Suspense components are streamed.

package.json

@@ -1,28 +1,30 @@
 {
-	"name": "simple-stack",
-	"version": "0.0.0",
-	"description": "Astro for apps",
-	"scripts": {
-		"dev": "turbo dev --filter='./packages/*'",
-		"dev:all": "turbo dev",
-		"build": "turbo build --filter='./packages/*'",
-		"build:all": "turbo build",
-		"check": "biome check packages/*",
-		"check:apply": "biome check packages/* --apply",
-		"lint": "biome lint packages/*",
-		"lint:apply": "biome lint packages/* --apply",
-		"format": "biome format",
-		"format:write": "biome format --write",
-		"version": "changeset version && pnpm install --no-frozen-lockfile && pnpm run check"
-	},
-	"keywords": ["withastro"],
-	"author": "bholmesdev",
-	"license": "MIT",
-	"devDependencies": {
-		"@biomejs/biome": "^1.4.1",
-		"@changesets/changelog-github": "^0.5.0",
-		"@changesets/cli": "^2.27.1",
-		"turbo": "^1.11.2"
-	},
-	"packageManager": "[email protected]"
+  "name": "simple-stack",
+  "version": "0.0.0",
+  "description": "Astro for apps",
+  "scripts": {
+    "dev": "turbo dev --filter='./packages/*'",
+    "dev:all": "turbo dev",
+    "build": "turbo build --filter='./packages/*'",
+    "build:all": "turbo build",
+    "check": "biome check packages/",
+    "check:apply": "biome check packages/ --apply",
+    "lint": "biome lint packages/",
+    "lint:apply": "biome lint packages/ --apply",
+    "format": "biome format",
+    "format:write": "biome format --write",
+    "version": "changeset version && pnpm install --no-frozen-lockfile && pnpm run check"
+  },
+  "keywords": [
+    "withastro"
+  ],
+  "author": "bholmesdev",
+  "license": "MIT",
+  "devDependencies": {
+    "@biomejs/biome": "^1.4.1",
+    "@changesets/changelog-github": "^0.5.0",
+    "@changesets/cli": "^2.27.1",
+    "turbo": "^1.11.2"
+  },
+  "packageManager": "[email protected]"
 }

packages/stream/src/middleware.ts

@@ -79,7 +79,11 @@ export const onRequest = defineMiddleware(async (ctx, next) => {
 					// The React team calls this server-side resolution "flushing."
 					setTimeout(() => {
 						const flushedChunk = flushableChunks.get(id) ?? chunk;
-						streamController.enqueue({ id, chunk: flushedChunk });
+						try {
+							streamController.enqueue({ id, chunk: flushedChunk });
+						} catch (e) {
+							streamController.error(e);
+						}
 						flushableChunks.delete(id);
 					}, FLUSH_THRESHOLD);
 					return;