Callbag factory that merges data from multiple callbag sources

Callbag operator that flattens a higher-order callbag source

Callbag factory that concatenates data from multiple callbag sources

debounce operator for callbag

Callbag factory that combines data from multiple callbag sources

Callbag source for lazy evaluation

Creates a new Callbag given an optional producer

Emits the values emitted by the source Callbag until a notifier Callbag emits a value

Callbag operator that applies a transformation on data passing through it

A callbag sink (listener) that connects an Observer a-la RxJS.

Callbag operator that conditionally lets data pass through

👜 Callbag source factory that emits values specified as arguments.

A callbag listener sink which is also a listenable source

Callbag operator that broadcasts a single source to multiple sinks

Callbag sink that consume both pullable and listenable sources

👜 Use callbag as React hook.

👜 Callbag source factory that immediately emits an error.

👜 Callbag which creates a source from a given factory when sink subscribes.

Callbag operator that limits the total amount of data sent through

A callbag listenable source that sends incremental numbers every x milliseconds