node.js - 当两个(!) 事件触发时执行 .on('end')

Question

我有一个节点应用程序，可以将两个文件作为流读取。我event.on('end')过去常常处理结果。问题是我真的不知道如何等待两个事件触发“结束”。

我现在拥有的是：

    reader1.on('end', function(){
        reader2.on('end',function(){ 
          doSomething();
        });
    }); 

对于小文件，这是可行的，但如果其中一个文件非常大，则应用程序会中止。

Answer 1

您的执行逻辑有些缺陷。你应该做这样的事情

var checklist = [];
 // checklist will contain sort of a counter
function reader_end(){
    if(checklist.length == 2 )
     // doSomething only if both have been added to the checklist
        doSomething();
}
reader1.on('end', function() {
    checklist.push('reader1');
    // increment the counter
    reader_end();
});
reader2.on('end', function() {
    checklist.push('reader2');
    reader_end();
});

尽管有一些库可以更好地处理这类事情，比如 Async 和 Promises。

---

使用异步，您需要使用compose

var r12_done = async.compose(reader1.on, reader2.on);
r12_done('end', function(){
    doSomething();
});

编辑：我刚刚注意到，由于可能reader1.on是一个没有标准回调参数签名的Stream 'end' 事件(err, results)，这可能不起作用。在这种情况下，你应该选择 Promise。

---

使用Promise你需要先Promisify然后加入

var reader1Promise = Promise.promisify(reader1.on)('end');
var reader2Promise = Promise.promisify(reader2.on)('end');

var reader12Promise = Promise.join(reader1Promise, reader1Promise);

reader12Promise.then(function(){
    doSomething();
});