Search results
190 packages found
Callbag operator that maps over values that satisfies a predicate. AKA filterMap
Callbag source that generates a range of numbers
Utility function for plugging callbag operators
Lossless throttle operator for callbags, enforcing a cooldown quiet time between emissions and queuing arrivals
Callbag proxy for solving circular dependencies
Callbag operator that pulls a source for a given number of times
Callbag operator that rejects all source elements that satisfies a predicate
callbag operator to repeat/restart stream by repeating handshake.
Convert an iterable or iterator to a callbag pullable source
Callbag operator that applies a transformation, which may be dot-notated path, on data passing through it
Callbag operator that merges all items a source of sources into a single output source
👜 Utility like callbag-pipe but wraps the operators calls in a tryCatch block, sending an eventual exception to the sink
👜Emits the interleaved values of the given iterables
Callbag factory that yields the Cartesian product (all combinations) of source callbags
Convert a pull-stream to a pullable callbag source
Use async-await to consume a pullable callbag source
Callbag operator for graceful error handling
Callbag operator that conditionally lets data pass through
Convert a listenable callbag source to an RxJS Observable
Like callbag-interval, but can be paused and resumed upon pulling