rx-async-filter

Asynchronous Filter Operator for RxJS

npm install rx-async-filter

Example

const Rx = require('rx-lite')
// works with 
require('rx-async-filter')(Rx)
 
  Rx.Observable.fromArray([1, 1, 2, 1, 1])
    .asyncFilter(async x => x === 2)
    .subscribe(() => t.end())