Node.JS-如何有条件地停止管道流

Question

我是java脚本的新手；nodejs。。。

我有一个文件处理流，它是由多个流组成的。效果很好。。。我想通过有条件地停止流的处理并在达到阈值时读取来增强这一点。

    inputStream.
    pipe(unzip()).
    pipe(latin1Decoder).
    pipe(
         combine(
                 through(function(obj){
                      //part-1 -
                      this.push(obj);
                      }),
                 through(function(obj){
                      //part-2-
                      this.push(obj);
                      })
         ));

在part-1中，如果我执行this.push(null)，则组合器将忽略传入输入。

然而，我无法停止阅读该文件。这很烦人，因为文件很大。

对我来说，从管线内部访问输入流以关闭它的最佳方式是什么？

Answer 1

好吧，以下是我最终解决它的方法：

    var cnt = 0;
    var processingStream = combine(unzip(), latin1Decoder(), part1(), part2());
    inputStream.pipe(processingStream);
    inputStream.on('data', function(x) {
      var lineCnt = x.toString().split(/rn|r|n/).length;
      cnt += lineCnt;
      if (cnt > 5) {
        inputStream.close();
        inputStream.unpipe(processingStream);
        processingStream.end();
      }          
    });

可能不是最有效的方法，但它符合我的要求。

请注意，inputstream是分块读取的，因此一次读取多行。