Search results
190 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.
Emits the values emitted by the source Callbag until a notifier Callbag emits a value
👜 Callbag operator which performs a side effect for every upwards emission (from sink to source), but other than that it acts as noop.
Emit the last value emitted from source on completion.
A callbag subject (listener, sink) that repeats its last value on connection.
👜 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 drops emitted values from source until provided observable emits.
👜 Callbag operator that emits the previous and current values as an array.
👜 Callbag operator that buffers the stream until another stream emits a value.
Convert any pullable callbag source to an AsyncIterable
👜 Callbag operator that emits the single value at the specified index.
👜 Callbag operator that maps to object properties.
👜 Callbag operator which emits a given value when source completes without emitting any value.
👜 Callbag operator which emits the value with time elapsed since last emission.