Use event-stream #1
Description
on('finish') and on('error') don't cover all cases, so sometimes this events fire before pipe really ends.
It's better to use es.wait from event-stream package.
module.exports = function (stream) {
return new Promise(function (resolve, reject) {
stream.pipe(es.wait(error => {
if (error) {
reject(error);
} else {
resolve();
}
}))
})
}