Callbag Packages

Callbag operator that conditionally lets data pass through

Callbag operator that limits the total amount of data sent through

A callbag listenable source that sends incremental numbers every x milliseconds

Callbag factory that combines data from multiple callbag sources

Convert a Promise to a callbag listenable source

Convert an observable to a callbag listenable source

Callbag operator that skips the first N data points of a source

Convert an iterable or iterator to a callbag pullable source

Callbag operator that combines consecutive values from the same source

Basic callbag factories and operators to get started with

👜 Callbag operator which errors if source does not emit before specified duration.

debounce operator for callbag

Creates a new Callbag given an optional producer

👜 Callbag operator that drops consecutive duplicate values

👜 Callbag operator which shares input stream between subscribers and emits last emitted value upon subscription.

👜 Callbag operator which performs a side effect for every upwards emission (from sink to source), but other than that it acts as noop.

👜 Callbag source factory that immediately emits an error.

👜 Callbag operator which converts source to a promise containing last emitted value.

👜 Callbag operator which resubscribes to the source given amount of times.

👜 Callbag operator that emits only the last item emitted by the source.