cf
callbag-filter
npm i callbag-filter
cf

callbag-filter

👜 Callbag operator that conditionally lets data pass through

by André Staltz

1.1.0 (see all)License:MITTypeScript:Built-In
npm i callbag-filter
Readme

/**

  • callbag-filter

  • Callbag operator that conditionally lets data pass through. Works on either
  • pullable or listenable sources.
  • npm install callbag-filter
  • Example:
  • const fromIter = require('callbag-from-iter');
    
  • const iterate = require('callbag-iterate');
    
  • const filter = require('callbag-filter');
    
  • const source = filter(x => x % 2)(fromIter([1,2,3,4,5]));
    
  • iterate(x => console.log(x))(source); // 1
    
  •                                       // 3
    
  •                                       // 5
    
    */

const filter = condition => source => (start, sink) => { if (start !== 0) return; let talkback; source(0, (t, d) => { if (t === 0) { talkback = d; sink(t, d); } else if (t === 1) { if (condition(d)) sink(t, d); else talkback(1); } else sink(t, d); }); };

module.exports = filter;

Downloads/wk

2K

GitHub Stars

5

LAST COMMIT

4yrs ago

MAINTAINERS

2

CONTRIBUTORS

3

OPEN ISSUES

0

OPEN PRs

0
VersionTagPublished
1.1.0
latest
4yrs ago
No alternatives found
No tutorials found
Add a tutorial

Rate & Review

100
No reviews found
Be the first to rate