在不结束基础流的情况下使用等待中断

Question

在 Node.js 项目中，我使用了一个带有可读流的for await of循环作为数据源，所以我的代码在概念上看起来像这样：

for await (const item of readableStream) {
// ...
}

可读流存在于循环之前，即它没有为循环创建，但它已经存在。现在的重点是我希望能够停止收听此流，即我想从循环中break，但我不想关闭可读流。

如果我只是这样做：

for await (const item of readableStream) {
if (condition) {
break;
}
// ...
}

循环按预期停止，但流关闭。如何在不关闭流的情况下实现相同的目标？

我不能直接使用on('data')，因为我想采取的行动包括运行async函数，因此这不起作用。我知道我可以使用Transform或Writable流来解决此问题，但这似乎是我想避免的一些开销。

我想做的是for await of循环吗？如果是，如何做？如果没有，我最好的选择是什么？

Answer 1

可以通过使用承诺的事件发射器侦听data事件来实现此行为。

p-event为此目的支持异步迭代器：

const asyncIterator = pEvent.iterator(readableStream, 'data', {
resolutionEvents: ['finish']
});
for await (const item of asyncIterator ) {
if (condition) {
break;
}
// ...
}