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

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

Callbag operator that limits the total amount of data sent through

👜 Callbag source that never completes and emits no data.

keyed callbag states

👜 Callbag source that emits no data and completes immediately.

👜 Callbag source factory that immediately emits an error.

Callbag listenable source sending DOMHighResTimeStamp at display refresh rate

Callbag-based State Management

Create a callbag listenable source from events on a DOM node

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

👜 Callbag operator that drops consecutive duplicate values

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

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

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

Callbag operator that seeds a source with an initial data output

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

👜 Callbag operator that splits the source into two, based on predicate function.

👜 Callbag listenable source which emits milliseconds elapsed since the subscription (using requestAnimationFrame) - useful for animations.

👜 Callbag operator that emits the previous and current values as an array.