search

cloudnc / observable-webworker

Simplified API for working with Web Workers with RxJS
https://cloudnc.github.io/observable-webworker
MIT License
225 stars 15 forks source link

Add helper operator `concurrentConcatAll()` to allow for ordered output #22

Open zakhenry opened 5 years ago

zakhenry commented 5 years ago

Currently if you pass concatAll() to the fromWorkerPool options, you will get the expected output but not the expected performance, as concatAll() does not subscribe to the next outer observable until the current inner one has completed.

There is no operator that subscribes to all outer operators asap, but buffers the emissions from inner observables that are further back in the queue.

zakhenry commented 3 years ago

Related RxJS core issue that would also resolve this https://github.com/ReactiveX/rxjs/issues/5519