Callbag Packages

Convert an iterable or iterator to a callbag pullable source

Convert a pull-stream to a pullable callbag source

👜 Callbag operator which buffers source values until separator stream emits.

👜 Callbag operator which buffers source values until provided time has passed.

Callbag factory that yields the Cartesian product (all combinations) of source callbags

Callbag operator that catches errors thrown by pullable and listenable sources

common callbags

Connect a react component to callbag(s)

👜 Callbag operator that drops all events after the first event for which predicate returns true.

👜 Callbag operator that emits the single value at the specified index.

Expressions with callbags

Callbag operator that conditionally lets data pass through

Callbag operator that emits only the first value emitted by the source Callbag that meets some condition given a predicate function. Works for listenable and pullable sources.

Emit the first value

callbag operator that applies data to a transformation passing through it

👜 Callbag operator which emits a given value when source completes without emitting any value.

👜 Callbag operator

callbag that distributes (shared) sources to many sinks

Callbag

Callbag sink/source.