filter-async-rxjs-pipe

Some pipeable functions for rxjs 7+ which accept predicate lambdas with async return value (Promise or Observable)

throttle-async-rxjs-pipe

A pipe functions for rxjs 7+ which accepts a 'wait' observable, emits 1 elements of the source stream and waits for an event on the 'wait' observable.