Detalhes do pacote

/**

• callbag-for-each

*

• Callbag sink that consume both pullable and listenable sources. When called
• on a pullable source, it will iterate through its data. When called on a
• listenable source, it will observe its data. *
• npm install callbag-for-each *
• Examples

*

• Consume a pullable source: *
• const fromIter = require('callbag-from-iter');
• const forEach = require('callbag-for-each'); *
• const source = fromIter([10,20,30,40]) *
• forEach(x => console.log(x))(source); // 10
• // 20
• // 30
• // 40 *
• Consume a listenable source: *
• const interval = require('callbag-interval');
• const forEach = require('callbag-for-each'); *
• const source = interval(1000); *
• forEach(x => console.log(x))(source); // 0
• // 1
• // 2
• // 3
• // ... */

const forEach = operation => source => { let talkback; source(0, (t, d) => { if (t === 0) talkback = d; if (t === 1) operation(d); if (t === 1 || t === 0) talkback(1); }); };

module.exports = forEach;