4

jsのStreamについて勉強しています。
readableイベントについて勉強するために
下記のコードを書いたのですが、うまく動きません。

helloworld.txtの内容をconsoleに表示 -> MyPushを付け加える -> process.stdout
(標準出力)に送る

ということがしたいのですが、どうやら、process.stdoutにnullが送られているようです。
どうすればいいのでしょうか?
ちなみに iojs --harmony_arrow_functionsで動かしています。


var Transform = require("stream").Transform;
var util = require("util");
var fs = require("fs");
var StringDecoder = require("string_decoder").StringDecoder;
var process = require("process");
util.inherits(MyStream, Transform);

function MyStream() {
    Transform.call(this);
}


MyStream.prototype._transform = (chunk, encoding, callback) => {
    var data = chunk;
    var utf8decoder = new StringDecoder("utf8");
    var decoded_data = utf8decoder.write(data);
    var send_data = decoded_data + "MyPush\n";
    this.push(send_data);

    callback();
}




var readable_stream = fs.createReadStream("helloworld.txt");
readable_stream.on("readable", () => {
    var chunk = readable_stream.read();
    console.log("Data", chunk);
});

readable_stream.on("end", () => {
    console.log("end");
});
var mystream = new MyStream();
mystream.on("readable", () => {
   var chunk = mystream.read();
    mystream.write(chunk);

})
readable_stream.pipe(mystream).pipe(process.stdout);


1 件の回答 1

2

おそらくですが...

read() メソッドによるデータの読み出しと、pipeによるデータの読み出しが衝突しているものと思います。
イベントによって受信したデータを配布するdataイベントと異なり、read()メソッドはキューからデータを取り出します (readableはキューにデータが入ってきたことを通知するイベント)。
そのため、誰かがデータを取り出すとキューが空になってしまうのではないかと。

(Node v0.12.2 で実行したところ、逆に read() メソッドの結果が null でした)

2
  • readで先に読み出して、bufferが空になってしまっているのに、pipeでもう一度読み出そうとしているから、nullが返ってしまうということでしょうか? Commented 2015年4月14日 13:31
  • はい。その通りです。
    – mysticatea
    Commented 2015年4月14日 13:35

この質問に回答するには、ログインする必要があります。

求めていた回答ではありませんか? のタグが付いた他の質問を参照する。