use feed.flow()

Inist-CNRS · Dec 13, 2020 · 675028c · 675028c
1 parent 89b434b
commit 675028c
Showing 1 changed file with 4 additions and 7 deletions.
diff --git a/packages/core/src/statements/spawn.js b/packages/core/src/statements/spawn.js
@@ -31,11 +31,8 @@ export default function spawn(data, feed) {
         statements = ezs.compileCommands(commands, this.getEnv());
     }
     const input = ezs.createStream(ezs.objectMode());
-    ezs.createPipeline(input, statements)
-        .pipe(ezs.catch((e) => feed.write(e))) // avoid to break pipeline at each error
-        .on('error', (e) => feed.stop(e))
-        .on('data', (d) => feed.write(d))
-        .on('end', () => feed.end());
-    ezs.writeTo(input, data, () => true);
-    return input.end();
+    const output = ezs.createPipeline(input, statements)
+        .pipe(ezs.catch((e) => feed.write(e))); // avoid to break pipeline at each error
+    ezs.writeTo(input, data, () => input.end());
+    return feed.flow(output);
 }