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.

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.

A custom element that sets its contents from a callbag stream

Convert any pullable callbag source to an AsyncIterable

👜 Callbag operator which accumulates source values until a separator emits

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

Callbag-based State Management

Callbag operator that returns data passing through it via a callback

lib to create observable and iterable based on callbag specs

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

callbag operator that applies data to a transformation passing through it

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.

Convert an iterable or iterator to a callbag pullable source

Convert a pull-stream to a pullable callbag source