Callbag Packages

👜 Callbag operator that maps to object properties.

Callbag proxy for solving circular dependencies

Proof of concept that implements a subset of RxJS using callbags

Callbag operator that pulls a source for a given number of times

👜 Callbag operator that samples from source when provided listenable emits.

Callbag source that generates a range of numbers

👜 Callbag operator that attaches a timestamp to each emitted value.

Use async-await to consume a pullable callbag source

👜 Callbag operator which emits the value with time elapsed since last emission.

Convert a pullable callbag source to a pull-stream source

Convert a listenable callbag source to an RxJS Observable

Convert a synchronous pullable callbag source to an Iterable

Expose a listenable callbag source as a mobx observable

Callbag operator that logs values to the console for simpler debugging

👜 Callbag source factory from WebSocket.

👜 Callbag operator

A callbag operator that maps items to sources and flattens them lazily

Convert a Promise to a callbag listenable source

👜 Callbag source factory

👜 Callbag source factory from addHandler and removeHandler pair.