我正在开发一个 node.js 项目。是否可以从流中异步准确地读取 n 字节？
通常，如果我想异步读取流，我会使用事件。问题是我也需要异步处理流的其余部分。
如果我监听data 事件，我可以稍后使用流的其余部分，但我无法控制一次要读取多少字节。我尝试使用unshift 将未使用的字节放回缓冲区，但这似乎不会在稍后添加另一个侦听器时触发data 事件。
This question 类似，但唯一的答案是同步解决方案。
是否有限制传递给data 事件侦听器的字节数的选项？是否有可能以某种方式将字节推回流中，并且仍然可以通过事件访问它们？
【问题讨论】：
标签： javascript node.js asynchronous stream
只要您正在收听readable 事件并且没有进行调用stream.read(n); 的阻塞查看，那么该解决方案就是异步的。像下面这样的东西（未经测试！）应该可以得到你想要的。
function streamChunk(stream, size, dataCallback, doneCallback) {
function getChunk() {
var data = stream.read(size);
if(data != null) {
dataCallback(data);
setImmediate(getChunk);
}
}
stream.on('readable', getChunk);
stream.on('end', doneCallback);
}
【讨论】：
removeListener。
stream.read 所有缓冲后，它不应该触发另一个可读事件数据。 nodejs.org/api/stream.html#stream_event_readable
readable 事件，因此您的侦听器将再次读取数据。我错了吗？
readable 事件？如果是后者，那是设计使然。 readable 事件不一定会在 all 数据准备好读取时调用，而是在 some 数据准备好时调用。您应该在每个流中获得多个 readable 事件调用，并且您依靠 end 事件知道您已经完成了。