rxjs for await:用于使RxJS通过AsyncIterables支持async await for await循环的库 源码

rxjs-for-wait 用于使RxJS通过AsyncIterables支持async-await for-await循环的库 四个策略 该库提供了4种不同的方式来使用 ,通过async / await for await..of循环使用可观察的AsyncIterable 。 这些策略中的每一个都有优点和缺点,因此在选择适合您需求的策略时要注意这些策略。 eachValueFrom(无损) async function example ( ) { const source$ = interval ( 100 ) ; for await ( const value of eachValueFrom ( source$ ) ) { console . log ( value ) ; } } 该策略将产生可观察源发出的每个单个值,一次产生一个值,直到可观察完成或错误为