在Highland.js中减少打印结果

Question

我写了一个简单的脚本，应该算行

var
  H = require('highland'),
  fs = require('fs'),
  split = require('split');

var lineStream = fs.createReadStream('data-samples/sample.log').pipe(split());

H('data', lineStream).reduce(0, function(count) {
  return count + 1;
}).each(console.log);

但出于某些原因，我在控制台里什么也没看到。文档中提到了懒散，但是each调用应该“调用”流。如何解决这个问题？

NB:，这是一个关于highland.js的问题，而不是关于行数的方法

Answer 1

“减少”流只发出终值。您应该提供.nil作为高地流的最终值。就像这样：

lineStream.on('end', function() { s.write(H.nil) });

还有Highland.js 本机支持节点流，所以您不需要创建事件流。用途：

H(lineStream)

相反，

H('data', lineStream)