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