node.js の新しい stream2 API について少し混乱しています。書き込み可能なストリームを作成しようとしましたが、「_end」関数を定義する方法が見つかりません。オーバーライドできるのは「_write」関数だけです。また、ドキュメントには、その方法を教えてくれるものは何もありません。
誰かが mystream.end() を呼び出した後、ストリームを適切に閉じる関数を定義する方法を探しています。
私のストリームは別のストリームに書き込み、ストリームを閉じた後、すべてのデータが送信された後に基になるストリームも閉じたいと考えています。
どうすればいいですか?
どのように見えるか:
var stream = require("stream");
function MyStream(basestream){
this.base = basestream;
}
MyStream.prototype = Object.create(stream.Writable);
MyStream.prototype._write = function(chunk,encoding,cb){
this.base.write(chunk,encoding,cb);
}
MyStream.prototype._end = function(cb){
this.base.end(cb);
}