rxjs-exhaustmap-with-trailing

A variant of RxJS exhaustMap that includes the trailing value emitted from the source observable while waiting for the inner observable to complete

callbag-switch-map-operator

A pure-callbag-operator implementation of switch-map (not exactly flat-map) for callbags 👜