Tag: reactivex

RxJs: Abort a deferred and shared observable when all unsubscribe

javascript observable reactivex rxjs typescript

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 to share the results It should abort the polling and call cancel if there

Implement for-await-of statement in RxJS

angular asynchronous javascript reactivex 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 without resolving the promise inside the pipe rather than converting