使用break in for await-of而不结束底层流

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

通过使用promisified事件发射器监听data事件，可以实现此行为。

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

const asyncIterator = pEvent.iterator(readableStream, 'data', {
  resolutionEvents: ['finish']
});

for await (const item of asyncIterator ) {
  if (condition) {
    break;
  }

  // ...
}