node-lazyを使用してこの単純なコードを試しました:
var productStream = function (readstream) {
return new Lazy(readstream)
.lines.forEach(function (line) {
console.log(count++);
if (count > 10) {
console.log("Should stop");
readstream.pause();
}
return normalizeAttributes(JSON.parse(line.toString().slice(0, -1)));
})
}
console.log(productStream(fs.createReadStream(datafile)).take(5));
Lazy は 10 行目以降も停止せず、ファイル全体をスイープします。誰でも理由を説明できますか?ここで答えを見ましたが、ライブラリにバグがあるのか 、それとも他に何かする必要があるのか 知りたいです。