👜 Callbag operator which emits values emitted by the source as long as each value satisfies the given predicate, and then completes as soon as predicate is not satisfied. But call lastly function before callbag is over.
👜 Callbag operator which emits the value with time elapsed since last emission.
👜 Callbag operator that attaches a timestamp to each emitted value.
callbag that distributes (shared) sources to many sinks
👜 Callbag operator that drops all events after the first event for which predicate returns true.
👜 Callbag operator that emits the single value at the specified index.
Expressions with callbags
Callbag operator that conditionally lets data pass through
Callbag operator that emits only the first value emitted by the source Callbag that meets some condition given a predicate function. Works for listenable and pullable sources.
Emit the first value
A callbag operator that maps items to sources and flattens them lazily
Convert an iterable or iterator to a callbag pullable source
Proof of concept that implements a subset of RxJS using callbags
Callbag operator that pulls a source for a given number of times
👜 Callbag operator that samples from source when provided listenable emits.
Callbag source that generates a range of numbers
callbag-redux enhancer, inspired by redux-promise
keyed callbag states
A callbag implementation of a redux-like store
Callbag operator that applies a transformation, which may be dot-notated path, on data passing through it