有什么方法可以在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);