This is now merged into the monorepo bjesuiter/rxjs-operators
Some pipeable functions for rxjs 6+ which accept predicate lambdas with async return value (Promise or Observable).
See filter-async.spec.ts in Github for usage examples.
This rxjs 6+ pipe accepts a predicate function which returns a Thenable<boolean>
for filtering.
(e.g. any object with a 'then' method === Promise and custom promise implementations)
This rxjs 6+ pipe accepts a predicate function which returns an Observable<boolean>
for filtering.
Both of these functions have a parallel
flag to indicate,
that they should run the predicate function in parallel for each emitted event from the source observable.
However, this does not work currently and should be improved in a later release.