Search results
55 packages found
👜 Callbag operator that drops consecutive duplicate values
👜 Callbag operator that maps to inner source, subscribe and emit in order.
👜 Callbag operator that splits the source into two, based on predicate function.
👜 Callbag operator which buffers source values until provided time has passed.
👜 Callbag operator that accumulates results using a feedback loop that emits one value and feeds back another to be used in the next iteration.
👜 Callbag operator which performs a side effect for every upwards emission (from sink to source), but other than that it acts as noop.
👜 Callbag source that after given duration, emit numbers in sequence every specified duration.
👜 Callbag operator that buffers the stream until another stream emits a value.
👜 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.
👜 Callbag source factory from WebSocket.
👜 Callbag operator that emits the single value at the specified index.
👜 Callbag wrapper for xhr.
👜 Callbag operator that samples from source when provided listenable emits.
👜 Callbag operator which emits the value with time elapsed since last emission.
👜 Callbag operator that samples from source when provided listenable emits.
👜 Callbag operator that maps to object properties.
👜 Callbag operator which emits a given value when source completes without emitting any value.
👜 Callbag operator that attaches a timestamp to each emitted value.