callbag-observe
Callbag listener sink that gets data from any listenable source. Think of it as "observable.subscribe".
npm install callbag-observe
example
const interval = ;const observe = ; const source = ; source; // 0 // 1 // 2 // 3 // ...