test fixup

Signed-off-by: marcopiraccini <marco.piraccini@gmail.com>

Author: marcopiraccini

test/parallel/test-stream-pipeline.js

@@ -1753,24 +1753,20 @@ tmpdir.refresh();
 {
   // Errors thrown in Readable.map inside pipeline should not be
   // swallowed by AbortError when the source is an infinite stream.
-  async function run() {
-    await assert.rejects(
-      pipelinep(
-        new Readable({ read() { this.push('data'); } }),
-        new Transform({
-          readableObjectMode: true,
-          transform(chunk, encoding, callback) {
-            this.push({});
-            callback();
-          },
-        }),
-        (readable) => readable.map(async () => {
-          throw new Error('Boom!');
-        }),
-      ),
-      { message: 'Boom!' },
-    );
-  }
-
-  run().then(common.mustCall());
+  pipeline(
+    new Readable({ read() { this.push('data'); } }),
+    new Transform({
+      readableObjectMode: true,
+      transform(chunk, encoding, callback) {
+        this.push({});
+        callback();
+      },
+    }),
+    (readable) => readable.map(async () => {
+      throw new Error('Boom!');
+    }),
+    common.mustCall((err) => {
+      assert.strictEqual(err.message, 'Boom!');
+    }),
+  );
 }