callbag-for-each

/**

• 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;