unpipe的NodeJS如何正确地流

Question

我试图找出为什么.unpipe调用是无操作如果流已.pause之后被管道：

b.on('data', console.log.bind(console, "on b -> ")); 
c.on('data', console.log.bind(console, "on c -> ")); 

a.pause(); 

a.pipe(b); 
a.pipe(c); 

a.resume(); 

a.unpipe(b); 
a.unpipe(c); 
a.write("foo"); 

打印：

//on b -> foo 
//on c -> foo 

这似乎是因为拨打.pause()。但重要的是保持流暂停'直到所有流都被管道。 如何以优雅的方式解决此问题？

有机会将源流上的'data'事件侦听器附加为目标流的写入函数。

b.on('data', console.log.bind(console, "on b -> ")); 
c.on('data', console.log.bind(console, "on c -> ")); 

writeToB = b.write.bind(b); 
writeToC = c.write.bind(c); 


a.pause(); 

a.on('data', writeToB); 
a.on('data', writeToC); 

a.resume(); 

a.removeListener('data',writeToB); 
a.removeListener('data',writeToC); 

a.write("foo"); 

但是这种方法感觉像坏主意。

Answer 1

尝试在管道后连接数据事件。

连接数据事件会导致管道开始流动。

a.pipe(b); 
a.pipe(c); 

b.on('data', console.log.bind(console, "on b -> ")); 
c.on('data', console.log.bind(console, "on c -> ")); 

a.unpipe(b); 
a.unpipe(c); 
a.write("foo");