cloudnc/observable-webworker

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

zakhenry opened this issue · 1 comments

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.

Related RxJS core issue that would also resolve this ReactiveX/rxjs#5519