Utility function for plugging callbags together in chain
A tiny but capable push & pull stream library for TypeScript and Flow
👜 Callbag source factory that emits values specified as arguments.
Creates a new Callbag given an optional producer
👜 Callbag which creates a source from a given factory when sink subscribes.
Emits the values emitted by the source Callbag until a notifier Callbag emits a value
👜 Callbag operator that emits items given it as arguments after it finishes emitting items emitted by source.
👜 Callbag operator which shares input stream between subscribers and emits last emitted value upon subscription.
👜 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.
A callbag sink (listener) that connects an Observer a-la RxJS.
debounce operator for callbag
👜 Callbag operator which performs a side effect for every upwards emission (from sink to source), but other than that it acts as noop.
👜 Callbag operator which converts source to a promise containing last emitted value.
👜 Callbag source that after given duration, emit numbers in sequence every specified duration.
👜 Callbag operator which resubscribes to the source given amount of times.
👜 Callbag operator that maps to inner source, subscribe and emit in order.
👜 Callbag operator which errors if source does not emit before specified duration.
👜 Callbag listenable source which emits value describing time progress (number between 0 an 1) since the subscription (using requestAnimationFrame) - useful for animations.
A standard for JS callbacks
👜 Callbag listenable source which emits milliseconds elapsed since the subscription (using requestAnimationFrame) - useful for animations.
👜 Callbag source factory that immediately emits an error.
👜 Callbag operator that emits only the last item emitted by the source.
👜 Callbag operator that buffers the stream until another stream emits a value.
Callbag operator that applies a transformation on data passing through it