Some extra combinators is used in the new awaiting IO pacakge I'm
working on.
It seemed reasonable to first check with you if you're all agree on these before moving instead of creating a giant PR.
These operators are added together with some round-trip tests:
poll: periodically repeats a sequence
choose: selects only emits returning Some
switchMap: projects each source value to an Observable which is merged in the output Observable, emitting values only from the most recently projected Observable.
exhaustMap: projects each source value to an Observable which is merged in the output Observable only if the previous projected Observable has completed.
serve: concurrently invokes the specified factory to create observables as fast and often as possible and subscribes to all of them up to the default maximum concurrency.
consume: generates a sequence using the producer/consumer pattern.
Some of them are inspired by the Rxx package (like the serve and consume). switchMap and exhaustMap are ports form RxJs.
Love to hear your opinion.
Let me know if I should test something else, more, ... or any other suggestion!
Some extra combinators is used in the new awaiting IO pacakge I'm working on.
It seemed reasonable to first check with you if you're all agree on these before moving instead of creating a giant PR.
These operators are added together with some round-trip tests:
poll: periodically repeats a sequencechoose: selects only emits returningSomeswitchMap: projects each source value to an Observable which is merged in the output Observable, emitting values only from the most recently projected Observable.exhaustMap: projects each source value to an Observable which is merged in the output Observable only if the previous projected Observable has completed.serve: concurrently invokes the specified factory to create observables as fast and often as possible and subscribes to all of them up to the default maximum concurrency.consume: generates a sequence using the producer/consumer pattern.Some of them are inspired by the Rxx package (like the
serveandconsume).switchMapandexhaustMapare ports form RxJs.Love to hear your opinion. Let me know if I should test something else, more, ... or any other suggestion!