为什么在_flush完成之前，“完成”事件在Node.js转换流中触发？

Question

我希望只有传回给_flush的回拨 完成后，才会触发'完成'回调，但在_flush完成前触发。为什么？

var stream = require('stream').Transform(); 

// Nothing interesting here 
stream._transform = function (chunk, enc, next) { 
    next(); 
}; 

// _flush makes an async call. 
stream._flush = function (callback) { 
    console.log("Expecting 1st: Entering _flush "); 

    return process.nextTick(function() { 
    console.log("Expecting 2nd: Done with _flush"); 
    callback(); 
    }); 
}; 

stream.on('finish',function() { 
    console.log("Expecting 3rd: Entering finish callback-- should be flushed now."); 
}); 

stream.end("chunk"); 

的node.js stream documentation用于精加工说，当所有数据已刷新到底层系统事件时才会触发。

看着它看起来像意图source code for Node's Transform stream implementation是完成将触发只有当_flush回调被称为：

this.once('prefinish', function() { 
    if (util.isFunction(this._flush)) 
    this._flush(function(er) { 
     done(stream, er); 
    }); 
else 
    done(stream); 
}); 

无论我错过了一些东西或者这是与节点的变换流的错误。我认为这是前者，但没有发现我的问题。谢谢你的帮助！

更新：需要注意的是，如果我替换调用process.nextTick()一起sleep同步调用，为sleep模块提供，那么问题就会消失。该问题仅在_flush内由异步调用触发。

Answer 1

在节点v0.10，_flush() is called on 'finish'中，以便更明显地看到那是预期的。

然而，在master（v0.11.x）中，它看起来像是一个新的'prefinish'事件被发明，并且改变了一些事情。但是，如果你看the code，你会看到prefinish（）被调用哪个triggers _flush()。当prefinish（）在发射'prefinish'后返回时，会发出'finish'。它不会等待在执行此操作之前调用_flush（）回调。

因此，两个版本的结果行为是相同的。现在是否应该改变行为是一个单独的问题。你可以创建一个关于情况的github问题，看看是否有兴趣修改行为。

Answer 2

“完成”事件没有直接的控制，'_flush'不是可写入流的一部分。

使用PassThrough，在'完成'事件之后执行'this.resume（）'，您将得到'结束'事件。

或者，你可以跟着拉请求：https://github.com/nodejs/node-v0.x-archive/pull/7612

或者使用一个模块：https://github.com/TomFrost/FlushWritable