Search results
190 packages found
👜 Callbag wrapper for xhr.
Convert any pullable callbag source to an AsyncIterable
Tallbag operator that limits the total amount of data sent through
👜 Callbag operator that emits the single value at the specified index.
Tallbag operator that broadcasts a single source to multiple sinks
👜 Callbag operator which emits a given value when source completes without emitting any value.
👜 Callbag operator that samples from source when provided listenable emits.
👜 Callbag source factory from WebSocket.
👜 Callbag source factory from addHandler and removeHandler pair.
👜 Callbag operator that maps to object properties.
Tallbag operator that applies a transformation on data passing through it
👜 Callbag operator that samples from source when provided listenable emits.
👜 Callbag operator that drops all events after the first event for which predicate returns true.
Tallbag operator that conditionally lets data pass through
👜 Callbag operator that attaches a timestamp to each emitted value.
👜 Callbag operator which accumulates source values until a separator emits
👜 Callbag operator which emits the value with time elapsed since last emission.
Delays the emission of items from the source Callbag by a given timeout
Convert a readable stream (EventEmitter with data / end / error events) to a callbag listenable source
Tallbag operator that flattens a higher-order tallbag source