javascript-在不等待基础流的情况下使用for-await-of中的break

前端之家收集整理的这篇文章主要介绍了javascript-在不等待基础流的情况下使用for-await-of中的break 前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

在Node.js项目中,我使用带有可读流的for循环循环作为数据源,因此我的代码在概念上看起来像这样:

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

可读流存在于循环之前,即不会为循环创建,但已经存在.现在的要点是,我希望能够停止收听此流,即,我想从循环中中断,但我不想关闭可读流.

如果我只是这样做:

  1. for await (const item of readableStream) {
  2. if (condition) {
  3. break;
  4. }
  5. // ...
  6. }

循环按预期方式停止,但是流被关闭.如何在不关闭流的情况下实现同一目标?

我不能直接使用on(‘data’),因为我要执行的操作包括运行异步函数,因此这行不通.我知道我可以使用Transform或Writable流解决此问题,但这似乎是我要避免的开销.

我想通过await循环来做些什么,如果可以,怎么办?如果没有,我最好的选择是什么?

最佳答案
通过使用约定的事件发射器监听数据事件,可以实现此行为.

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

  1. const asyncIterator = pEvent.iterator(readableStream,'data',{
  2. resolutionEvents: ['finish']
  3. });
  4. for await (const item of asyncIterator ) {
  5. if (condition) {
  6. break;
  7. }
  8. // ...
  9. }

猜你在找的JavaScript相关文章