👜 Callbag operator that emits only the last item emitted by the source.
A tiny but capable push & pull stream library for TypeScript and Flow
👜 Callbag operator which shares input stream between subscribers and emits last emitted value upon subscription.
A standard for JS callbacks
debounce operator for callbag
👜 Callbag operator which converts source to a promise containing last emitted value.
Callbag operator that applies a transformation on data passing through it
Utility function for plugging callbags together in chain
Creates a new Callbag given an optional producer
👜 Callbag operator that buffers the stream until another stream emits a value.
👜 Callbag source factory that emits values specified as arguments.
Callbag factory that merges data from multiple callbag sources
👜 Callbag which creates a source from a given factory when sink subscribes.
Callbag sink that consume both pullable and listenable sources
👜 Callbag operator that emits items given it as arguments after it finishes emitting items emitted by source.
A callbag sink (listener) that connects an Observer a-la RxJS.
Callbag operator that conditionally lets data pass through
Callbag factory that concatenates data from multiple callbag sources
👜 Callbag source that emits no data and completes immediately.
👜 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.
Emits the values emitted by the source Callbag until a notifier Callbag emits a value
Callbag operator that broadcasts a single source to multiple sinks
👜 Callbag source that never completes and emits no data.
Convert an observable to a callbag listenable source