test: add coverage for pipeline

co-authored-by: jazelly <[email protected]> PR-URL: #56278 Reviewed-By: Matteo Collina <[email protected]>
nodejs · Dec 24, 2024 · 5ea6fa7 · 5ea6fa7
1 parent 6156f8a
commit 5ea6fa7
Showing 1 changed file with 27 additions and 0 deletions.
diff --git a/test/parallel/test-stream-pipeline.js b/test/parallel/test-stream-pipeline.js
@@ -1723,3 +1723,30 @@ tmpdir.refresh();
   });
   src.destroy(new Error('problem'));
 }
+
+{
+  async function* myAsyncGenerator(ag) {
+    for await (const data of ag) {
+      yield data;
+    }
+  }
+
+  const duplexStream = Duplex.from(myAsyncGenerator);
+
+  const r = new Readable({
+    read() {
+      this.push('data1\n');
+      throw new Error('booom');
+    },
+  });
+
+  const w = new Writable({
+    write(chunk, encoding, callback) {
+      callback();
+    },
+  });
+
+  pipeline(r, duplexStream, w, common.mustCall((err) => {
+    assert.deepStrictEqual(err, new Error('booom'));
+  }));
+}