1.0.5 • Published 7 years ago
rx-async-filter v1.0.5
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())