This is a proof of concept to demonstrate how an RxJS-style API can be built using callbags under the hood. It shows that the Callbag spec does not dictate the API you find in callbag-basics. Check the source code for this repo and you'll find that we use callbags as implementation, but the external API mimics RxJS.
npm install callbag-pseudo-rxjs
Pick the first 5 odd numbers from a clock that ticks every second, then subscribe to it:
const Observable = require('callbag-pseudo-rxjs');
Observable.interval(1000)
.map(x => x + 1)
.filter(x => x % 2)
.take(5)
.subscribe({
next: x => console.log(x),
error: e => {},
complete: () => {}
});
// 1
// 3
// 5
// 7
// 9Log XY coordinates of click events on <button> elements:
const Observable = require('callbag-pseudo-rxjs');
Observable.fromEvent(document, 'click')
.filter(ev => ev.target.tagName === 'BUTTON')
.map(ev => ({x: ev.clientX, y: ev.clientY}))
.subscribe({
next: x => console.log(x),
error: e => {},
complete: () => {}
});
// {x: 110, y: 581}
// {x: 295, y: 1128}
// ...