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;