Search results
190 packages found
Callbag operator that taps the source with the given function, but otherwise is a noop
A factory of Shadow Callbags useful for implementing Tallbags
Convert a readable stream (EventEmitter with data / end / error events) to a callbag listenable source
Callbag mock with manual emitting and signal tapping
Callbag operator that samples a pullable source when a listenable source emits
👜 Converts an async iterable or iterator into a callbag pullable source
Convert a synchronous pullable callbag source to an Iterable
Callbag operator that logs values to the console for simpler debugging
Convert an observable to a callbag listenable source
Create a callbag source from a function
Create a callbag listenable source from selector-filtered events on a DOM node
Throttle operator for callbags, enforcing a cooldown quiet time between emissions (during which arrivals are dropped)
Callbag operator that puts the previous value alongside the current
Callbag operator that turns a listenable source into a pullable, returning latest data on request
Callbag puller sink that iterates over a pullable source
A pure-callbag-operator implementation of flat-map for callbags 👜 (MOVED TO callbag-switch-map-operator)
Callbag operator that samples a pullable source and combines it with a listenable
Callbag operator that rescues a failed source
A pure-callbag-operator implementation of switch-map (not exactly flat-map) for callbags 👜
Callbag operator that changes data passing through it to a fixed value