fix: 🐛 avoid to write in closed stream

Inist-CNRS · Oct 12, 2023 · 27df67a · 27df67a
1 parent 8e74dfc
commit 27df67a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/packages/core/src/engine.js b/packages/core/src/engine.js
@@ -152,7 +152,9 @@ export default class Engine extends SafeTransform {
                 debug('ezs')(`Ignoring error at item #${currentIndex}`);
                 return this.push(createErrorWith(data, currentIndex, this.funcName, chunk));
             }
-            return this.push(data);
+            if (!this.errorWasSent) {
+                return this.push(data);
+            }
         };
         const wait = async () => {
             this.pause();

diff --git a/packages/core/src/statements/fork.js b/packages/core/src/statements/fork.js
@@ -49,8 +49,8 @@ export default function fork(data, feed) {
             this.whenFinish = new Promise((resolve) => output
                 .pipe(ezs.catch((e) => feed.write(e))) // avoid to break pipeline at each error
                 .once('error', (e) => feed.stop(e))
-                .once('end', resolve)
                 .on('data', () => true)
+                .once('end', resolve)
             );
         }
     }