有没有任何方法可以在NodeJS中重用管道转换链

Question

例如，如果我有

readableStream.pipe(ws1).pipe(ws2).pipe(ws3)

如何将转换链封装在一个函数中，然后在另一个转换链中重用它？

我想做一些这样的事情：

var transformationChain1 = readableStream.pipe(ws1).pipe(ws2).pipe(ws3)
readableStream2.pipe(transformationChain1).pipe(endWs)

Answer 1

您可能会使用

var combine = require('stream-combiner2')
var ws = combine(ws1, ws2, ws3);
readableStream2.pipe(ws).pipe(endWs);

Answer 2

也许我误解了（我的Node.js已经生锈了，所以这是完全可能的），但为什么不按照你说的做，并将其封装在一个函数中呢？

function transformationChain(rs) {
  return rs.pipe(ws1).pipe(ws2).pipe(ws3);
}
var transformationChain1 = transformationChain(readableStream);
readableStream2.pipe(transformationChain1).pipe(endWs);