I want to create an rxjs Observable that runs a long polling operation. Each iteration emits intermediate results. When isComplete returns true, the Observable completes. This function should behave as follows It should start only when there’s at least one subscriber It should allow multiple subscribers…
Tag: reactivex
Implement for-await-of statement in RxJS
I have the following statement: client.list() returns an async iterable iterator, and expects the use of for await…of to resolve the promises. I would like to incorporate the code into an existing rxjs pipe that instantiates the client. I looked everywhere and I couldn’t figure out how to do so wi…