Node.js可读流如何独立复制和使用？

Question

有没有一种方法来复制或发球的Node.js可读流，使这些流可以独立于相同的来源消耗？

我的使用情况看起来是这样的：

f(inputStream, callback(err, data) { 
    // do stuff with data to change how g behaves 
    g(inputStream); 
}); 

的要求是：f和g开始从流的开始阅读。我通常在这里使用readable.pipe，但g需要在回调中发生。

Answer 1

您可以将相同的可读流传递给f和g。他们将从彼此独立的流中读取。

例如： -

var fs = require('fs'); 
 
var str = fs.createReadStream('<file location>'); 
 

 

 
function f(s) { 
 
s.on('data', function (d) { 
 
     console.log(d.toString()); 
 
}); 
 
s.on('end', function() { 
 
     console.log('ended'); 
 
}); 
 
} 
 
function g(s) { 
 
s.on('data', function (d) { 
 
     console.log(d.toString()); 
 
}); 
 
s.on('end', function() { 
 
     console.log('ended'); 
 
}); 
 
} 
 

 
g(str); 
 
f(str);