callbag-map
v1.1.0
Published
Callbag operator that applies a transformation on data passing through it
Downloads
36,892
Readme
/**
- callbag-map
- Callbag operator that applies a transformation on data passing through it.
- Works on either pullable or listenable sources.
npm install callbag-map
- Example:
const fromIter = require('callbag-from-iter');
const iterate = require('callbag-iterate');
const map = require('callbag-map');
const source = map(x => x * 0.1)(fromIter([10,20,30,40]));
iterate(x => console.log(x))(source); // 1
// 2
// 3
// 4
*/
const map = f => source => (start, sink) => { if (start !== 0) return; source(0, (t, d) => { sink(t, t === 1 ? f(d) : d) }); };
module.exports = map;