@silvancodes/rxjs-fun
v1.0.0
Published
Some custom operators of mine.
Downloads
2
Readme
RxJS Fun
Some custom operators of mine.
queueMap
Similar to concatMap. Every emission of the outer stream adds to the queue. You can specify after how many emissions the active inner observable should make way for the next in the queue. Completion of inner observable automatically switches to next in queue.
Possible configuration is:
- minimalEmissions of inner observable (default: 1)
- exhaust queue after source completed (default: true)
- complete last inner observable after minimal emissions after source completed (default: false)