Add helper operator `concurrentConcatAll()` to allow for ordered output
zakhenry opened this issue · 1 comments
zakhenry commented
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
Related RxJS core issue that would also resolve this ReactiveX/rxjs#5519