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

👜 Callbag source factory that immediately emits an error.

👜 Callbag source that emits no data and completes immediately.

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

Create a callbag listenable source from events on a DOM node

👜 Callbag source that never completes and emits no data.

Convert a Promise to a callbag listenable source

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

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

👜 Callbag operator that drops consecutive duplicate values

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

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

Callbag listenable source sending DOMHighResTimeStamp at display refresh rate

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

Callbag operator that seeds a source with an initial data output

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

👜 Callbag source that after given duration, emit numbers in sequence every specified duration.

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

Callbag operator that taps the source with the given function, but otherwise is a noop

👜 Callbag operator that maps to inner source, subscribe and emit in order.