Search results
190 packages found
Callbag operator that merges all items a source of sources into a single output source
Callbag operator that returns data passing through it via a callback
Proof of concept that implements a subset of RxJS using callbags
Convert a Promise to a callbag listenable source
Utility function for plugging callbag operators
Callbag operator that conditionally lets data pass through
Callbag factory that yields the Cartesian product (all combinations) of source callbags
👜 Utility like callbag-pipe but wraps the operators calls in a tryCatch block, sending an eventual exception to the sink
Callbag operator that catches errors thrown by pullable and listenable sources
Convert an iterable or iterator to a callbag pullable source
Callbag operator that logs values to the console for simpler debugging
Callbag operator that applies a transformation, which may be dot-notated path, on data passing through it
Callbag operator that rejects all source elements that satisfies a predicate
Like callbag-interval, but can be paused and resumed upon pulling
Callbag operator that emits only the first value emitted by the source Callbag that meets some condition given a predicate function. Works for listenable and pullable sources.
Callbag operator that pulls a source for a given number of times
A callbag operator that maps items to sources and flattens them lazily
Convert a pull-stream to a pullable callbag source
Lossless throttle operator for callbags, enforcing a cooldown quiet time between emissions and queuing arrivals