Callbag Packages

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

Callbag source that generates a range of numbers

A reimplementation of redux using callbag

callbag-redux enhancer, inspired by redux-promise

Callbag operator that rejects all source elements that satisfies a predicate

callbag operator to repeat/restart stream by repeating handshake.

Callbag operator that rescues a failed source

Callbag operator that applies a transformation, which may be dot-notated path, on data passing through it

Callbag operator that changes data passing through it to a fixed value

Callbag operator that merges all items a source of sources into a single output source

👜 Callbag operator that maps to inner source, subscribe and emit in order.

Callbag operator version of merge

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

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

Use async-await to consume a pullable callbag source

Convert a synchronous pullable callbag source to an Iterable

Expose a listenable callbag source as a mobx observable

Convert a pullable callbag source to a pull-stream source

Specialized Callbags validated through schemas and hashes.

👂 A React render-prop component that listens to values emitted by callbags