A standard for JS callbacks
Callbag factory that merges data from multiple callbag sources
debounce operator for callbag
Callbag factory that concatenates data from multiple callbag sources
Callbag operator that flattens a higher-order callbag source
Callbag factory that combines data from multiple callbag sources
Emits the values emitted by the source Callbag until a notifier Callbag emits a value
Creates a new Callbag given an optional producer
Callbag source for lazy evaluation
👜 Callbag source factory that emits values specified as arguments.
Callbag operator that applies a transformation on data passing through it
Callbag operator that broadcasts a single source to multiple sinks
A callbag listener sink which is also a listenable source
A callbag sink (listener) that connects an Observer a-la RxJS.
Callbag operator that conditionally lets data pass through
Convert an observable to a callbag listenable source
Callbag sink that consume both pullable and listenable sources
A callbag listenable source that sends incremental numbers every x milliseconds
Callbag operator that limits the total amount of data sent through
👜 Callbag source that emits no data and completes immediately.
👜 Callbag which creates a source from a given factory when sink subscribes.
Convert a Promise to a callbag listenable source
👜 Callbag source that never completes and emits no data.
👜 Callbag source factory that immediately emits an error.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.