Callbags Packages

👜 Callbag source factory that emits values specified as arguments.

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

👜 Callbag listenable source which emits value describing time progress (number between 0 an 1) since the subscription (using requestAnimationFrame) - useful for animations.

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

👜 Callbag operator which emits values emitted by the source as long as each value satisfies the given predicate, and then completes as soon as predicate is not satisfied.

👜 Callbag operator that emits items given it as arguments after it finishes emitting items emitted by source.

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

👜 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.

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

👜 Callbag operator that drops emitted values from source until provided observable emits.

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

👜 Callbag source that emits no data and completes immediately.

👜 Callbag operator that maps to inner source and ignores other values until that source completes.

👜 Callbag source that never completes and emits no data.