1

我已经使用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 在第十行之后并没有停止,它扫过整个文件。谁能解释为什么?我在这里看到了答案,但我很好奇库中是否存在错误或我需要做的其他事情。

4

0 回答 0