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())