Try different streaming strategy

Wundero · Dec 4, 2024 · c13817d · c13817d
1 parent d1540e5
commit c13817d
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 5 deletions.
diff --git a/packages/core/jsr.json b/packages/core/jsr.json
@@ -1,7 +1,7 @@
 {
     "name": "@sinkr/core",
     "license": "MIT",
-    "version": "0.3.4",
+    "version": "0.3.5",
     "exports": {
         ".": "./src/index.ts"
     }

diff --git a/packages/core/package.json b/packages/core/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@sinkr/core",
-  "version": "0.3.4",
+  "version": "0.3.5",
   "type": "module",
   "main": "src/index.ts",
   "exports": {

diff --git a/packages/core/src/server.ts b/packages/core/src/server.ts
@@ -19,10 +19,8 @@ function preludeAndEncodeStream(
 ) {
   const reader = stream.getReader();
   const morphedUnencodedStream = new ReadableStream<unknown>({
-    start(controller) {
+    async start(controller) {
       controller.enqueue(prelude);
-    },
-    async pull(controller) {
       try {
         const { done, value } = await reader.read();
         if (done) {