node.js - 如何在 node.js 中编写转换流

Question

我有一个作为一系列转换流实现的 csv 解析器:

process.stdin
    .pipe(iconv.decodeStream('win1252'))
    .pipe(csv.parse())
    .pipe(buildObject())
    .pipe(process.stdout);

我想抽象解析器(在它自己的模块中)并能够做到:

process.stdin.
    .pipe(parser)
    .pipe(process.stdout);

其中 parser 只是之前使用的转换流的组合。

如果我这样做了

var parser = iconv.decodeStream('win1252')
    .pipe(csv.parse())
    .pipe(buildObject());

然后 parser 设置为 buildObject() 流，只有这个转换流接收数据。

如果我这样做了

var parser = iconv.decodeStream('win1252');
parser
    .pipe(csv.parse())
    .pipe(buildObject());

它也不起作用，因为 .pipe(process.stdout) 将在第一个转换流上被调用，而其他 2 个将被绕过。

有什么优雅的流组合推荐吗？

Answer 1

不幸的是，没有内置的方法可以做到这一点，但有很酷的 multipipe包裹。 像这样使用:

var multipipe = require('multipipe');

var parser = multipipe(iconv.decodeStream('win1252'), csv.parse(), buildObject());