Search results
190 packages found
Extension of the Callbag spec to add operator metadata
👜 Callbag operator which buffers source values until provided time has passed.
Callbag operator that skips the first N data points of a source
👜 Callbag operator that accumulates results using a feedback loop that emits one value and feeds back another to be used in the next iteration.
A callbag subject (listener, sink) that repeats its last value on connection.
👜 Callbag operator which performs a side effect for every upwards emission (from sink to source), but other than that it acts as noop.
Create a Callbag from any object with on/off methods, a DOM EventTarget, or a Node.JS EventEmitter.
Callbag operator that seeds a source with an initial data output
Emit the last value emitted from source on completion.
apply streaming operators (like debounce) on your component state / props
👜 Callbag source that after given duration, emit numbers in sequence every specified duration.
👜 Callbag operator that maps to inner source and ignores other values until that source completes.
👜 Callbag operator that emits the previous and current values as an array.
👜 Callbag operator that drops emitted values from source until provided observable emits.
A callbag operator that flattens/merges sources
Basic callbag factories and operators to get started with
Callbag operator that taps the source with the given function, but otherwise is a noop
A callbag operator that switches to latest listenable source result
Convert a listenable callbag source to ES Observable
👜 Callbag operator that buffers the stream until another stream emits a value.