基本ノードStream.Readableの例を実装するにはどうすればよいですか？

Question

私はストリームを学習しようとしており、問題が少しでもうまくいけばうまく動作します。

この例では、静的オブジェクトをストリームにプッシュし、そのストリームをサーバーレスポンスにパイプするだけです。

これまで私がこれまで持っていたことはありますが、多くは機能しません。ストリームをコンソールに出力するだけでも、それを自分のレスポンスにパイプする方法を知ることができます。

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

var MyStream = function(options) { 
    Readable.call(this); 
}; 

MyStream.prototype._read = function(n) { 
    this.push(chunk); 
}; 

var stream = new MyStream({objectMode: true}); 
s.push({test: true}); 

request.reply(s); 

Answer 1

現在のコードにはいくつか問題があります。

1. リクエストストリームは、おそらくバッファモードストリームです。つまり、オブジェクトに書き込むことはできません。幸いにも、あなたは間違いが何の問題も引き起こさないように、Readableのコンストラクタにオプションを渡すことはありませんが、意味的には間違っており、期待される結果が得られません。
2. Readableのコンストラクタを呼び出しますが、プロトタイププロパティは継承しません。 Readableをサブクラス化するには、util.inherits()を使用してください。
3. chunk変数はコードサンプルのどこにも定義されていません。ここで

実施例である：

var util = require('util'); 
var Readable = require('stream').Readable; 

var MyStream = function(options) { 
    Readable.call(this, options); // pass through the options to the Readable constructor 
    this.counter = 1000; 
}; 

util.inherits(MyStream, Readable); // inherit the prototype methods 

MyStream.prototype._read = function(n) { 
    this.push('foobar'); 
    if (this.counter-- === 0) { // stop the stream 
    this.push(null); 
    } 
}; 

var mystream = new MyStream(); 
mystream.pipe(process.stdout);