node.js - Node 流 promise 错误处理

Question

我有这样的代码:

let generateSmth = function(len, j, stream, headers) {

    len--;
    j++;

    if (len === 0) {
        stream.write(headers.map(function(v) {return v + '_' + j;}));
        stream.end();
    } else {
        if (stream.write(headers.map(function(v) {return v + '_' + j;}))) {
            generateSmth(len, j, stream, headers);
        } else {
            stream.once('drain', ()=>{generateSmth(len, j, stream, headers)});
        }
    }
};
const fs = require('fs'),
      myStream = fs.createWriteStream('test.txt');
let myPromise = new Promise((resolve, reject)=>{
    try {
        generateSmth(10000, 0, ()=>{
            resolve(()=>{

            });
        }, myStream);
    } catch (error) {
        reject(error);
    }
});

我了解到try/catch不是捕获generateSmth函数中错误的适当方法。但是，如果我在函数中使用流，我不明白如何捕获错误？
有人可以帮我吗？谢谢。

Answer 1

在Promise构造函数中添加以下内容:

myStream.on('error', reject)