Callbag Packages

Callbag operator. Transform the source data and pipe it.

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

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

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

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

Callbag-based State Management

Convert any pullable callbag source to an AsyncIterable

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

Callbag operator that returns data passing through it via a callback

A custom element that sets its contents from a callbag stream

👜 Callbag operator which accumulates source values until a separator emits

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 accumulates results using a feedback loop that emits one value and feeds back another to be used in the next iteration.

Lossless throttle operator for callbags, enforcing a cooldown quiet time between emissions and queuing arrivals

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