Search results
190 packages found
👜 Callbag operator which shares input stream between subscribers and emits last emitted value upon subscription.
Callbag operator that limits the total amount of data sent through
Promises but lazy and cancellable
Convert a Promise to a callbag listenable source
A callbag listenable source that sends incremental numbers every x milliseconds
Basic callbag factories and operators to get started with
Convert an observable to a callbag listenable source
keyed callbag states
Expressions with callbags
👜 Callbag operator that maps to inner source, subscribe and emit in order.
👜 Callbag operator that drops consecutive duplicate values
Creates a new Callbag given an optional producer
👜 Callbag operator which buffers source values until separator stream emits.
Convert an iterable or iterator to a callbag pullable source
A factory of Shadow Callbags useful for implementing Tallbags
Callbag factory that combines data from multiple callbag sources
Callbag listener sink that gets data from any listenable source
👜 Callbag operator that splits the source into two, based on predicate function.
Callbag operator that Drops consecutive duplicate
Callbag operator that combines consecutive values from the same source