observable-webworker icon indicating copy to clipboard operation
observable-webworker copied to clipboard

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

Open zakhenry opened this issue 6 years ago • 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.

zakhenry avatar Aug 09 '19 08:08 zakhenry

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

zakhenry avatar Mar 23 '21 07:03 zakhenry