fix: ignore error if stream is ended

marko-js · May 29, 2024 · 39eaf14 · 39eaf14
1 parent 3514bad
commit 39eaf14
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/src/util/stream.ts b/src/util/stream.ts
@@ -113,7 +113,6 @@ export function createWritable(): StreamWritable {
     },
     error(reason: unknown) {
       error = reason;
-      done = true;
       buf = "";
 
       if (pending) {
@@ -122,10 +121,6 @@ export function createWritable(): StreamWritable {
       }
     },
     async next() {
-      if (error) {
-        throw error;
-      }
-
       if (buf) {
         const value = buf;
         buf = "";
@@ -142,6 +137,10 @@ export function createWritable(): StreamWritable {
         };
       }
 
+      if (error) {
+        throw error;
+      }
+
       await (pending = createDeferred());
       return this.next();
     },