34 lines
659 B
Plaintext
34 lines
659 B
Plaintext
'use strict';
|
|
|
|
module.exports = stream => {
|
|
if (stream.listenerCount('error') !== 0) {
|
|
return stream;
|
|
}
|
|
|
|
stream.__destroy = stream._destroy;
|
|
stream._destroy = (...args) => {
|
|
const callback = args.pop();
|
|
|
|
stream.__destroy(...args, async error => {
|
|
await Promise.resolve();
|
|
callback(error);
|
|
});
|
|
};
|
|
|
|
const onError = error => {
|
|
// eslint-disable-next-line promise/prefer-await-to-then
|
|
Promise.resolve().then(() => {
|
|
stream.emit('error', error);
|
|
});
|
|
};
|
|
|
|
stream.once('error', onError);
|
|
|
|
// eslint-disable-next-line promise/prefer-await-to-then
|
|
Promise.resolve().then(() => {
|
|
stream.off('error', onError);
|
|
});
|
|
|
|
return stream;
|
|
};
|