Promisified version of pipeline() doesn't throw the same error that's sent to pipeline()'s error handler.

[spaghetti-is-pasta]

• Version: v11.13.0
• Platform: Linux 3.10.0-693.21.1.el7.x86_64
• Subsystem: stream

This works as expected:

const fs = require('fs');
const { pipeline } = require('stream')

pipeline(
    process.stdin,
    fs.createWriteStream("/un-writable-file"),
    e => console.error("this should happen")
);

// prints "this should happen"

However, this equivalent, using the promisified version of pipeline doesn't throw the same error:

const fs = require('fs');
const stream = require('stream')
const { promisify } = require('util');
const pipelinePromise = promisify(stream.pipeline);

(async () => {

   try {
      pipelinePromise(
         process.stdin,
         fs.createWriteStream("/un-writable-file")
      )
   }
   catch (e) {
      console.log("this should happen");
   }

})()

// An unhandled exception is thrown. "this should happen" is *not* printed.

I believe that if the error handler was properly called using pipeline(), then the promisified version should behave the same, but with the error being thrown.

[Hakerh400]

It should be await pipelinePromise(...)

[spaghetti-is-pasta]

duh, thanks!