188 packages found
A tiny but capable push & pull stream library for TypeScript and Flow
Create a callbag listenable source from events on a DOM node
Basic callbag factories and operators to get started with
Callbag operator that flattens a higher-order callbag source
A callbag implementation of a redux-like store
Callbag operator that applies a transformation on data passing through it
A callbag listener sink which is also a listenable source
Callbag operator that broadcasts a single source to multiple sinks
Utility function for plugging callbags together in chain
Callbag factory that merges data from multiple callbag sources
Callbag operator that conditionally lets data pass through
A callbag listenable source that sends incremental numbers every x milliseconds
Convert an iterable or iterator to a callbag pullable source
Callbag source that after given Date emits numbers in sequence to a specified period.
Callbag factory that concatenates data from multiple callbag sources
A Callbag operator that converts a listenable source into a pullable one by batching data between requests.
Callbag operator that limits the total amount of data sent through
Convert a Promise to a callbag listenable source
Callbag factory that combines data from multiple callbag sources
A implementation of the interval operator that emits immediately