filter-async-rxjs-pipe
    TypeScript icon, indicating that this package has built-in type declarations

    1.0.1 • Public • Published

    filter-async-rxjs-pipe

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

    Usage

    See filter-async.spec.ts in Github for usage examples.

    Provided rxjs 6+ pipes

    filterByPromise

    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)

    filterAsync

    This rxjs 6+ pipe accepts a predicate function which returns an Observable<boolean> for filtering.

    Note

    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.

    Install

    npm i filter-async-rxjs-pipe

    DownloadsWeekly Downloads

    80

    Version

    1.0.1

    License

    Apache-2.0

    Unpacked Size

    5.39 kB

    Total Files

    6

    Last publish

    Collaborators

    • bjesuiter