test: add coverage for pipeline

co-authored-by: jazelly <xzha4350@gmail.com> PR-URL: #56278 Reviewed-By: Matteo Collina <matteo.collina@gmail.com>

Author: 2 people

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'));
+ }));
+}