Callbag Packages

Callbag operator. Transform the source data and pipe it.

utility that chains callbags

Stops pipeline data from the source when a specified limit is reached.

👜 Callbag operator which accumulates source values until a separator emits

Callbag operator that returns data passing through it via a callback

A custom element that sets its contents from a callbag stream

A pure-callbag-operator implementation of flat-map for callbags 👜 (MOVED TO callbag-switch-map-operator)

A callbag operator that passes through only sequences with minimum length.

Callbag operator that maps over values that satisfies a predicate. AKA filterMap

Callbag-based State Management

Convert any pullable callbag source to an AsyncIterable

Refract bindings for Redux with Callbag: harness the power of reactive programming to supercharge your components!

lib to create observable and iterable based on callbag specs

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

Convert a listenable callbag source to an RxJS Observable

Callbag operator that logs values to the console for simpler debugging

👜 Callbag source factory from WebSocket.