Fast, simple data pipelines
group incoming items until either max item count is reached or no new items arrived for a while (like pull-group but with a timeout)
data event streams made easy, built on top of PipeStreams, which is built on top of pull-stream
pull-stream source for exponential backoff intervals
Like pull.drain, but respects CPU load
Protocol Buffers length-prefixed pull-stream encoder/decoder
Simple pull-streams for websocket client connections
Pull streams implementation of a file reader
A through stream that does CPU throttling to avoid full CPU usage
pull-stream that groups items by return value of a user-defined function
Sink ssb-review streams into mutant arrays
Pull streams over window.postMessage
A pull-stream that filters until X elements, and stops streaming after Y elements.
Wrap handlers to use pull-stream
A refinement of the parallel map module for dynamic, unbounded, and fault-tolerant parallel processing.
Scan algorithm for pull streams
transform input into equally-sized blocks of output
Lends one value at a time from a stream. Re-lends in case of errors.
Pull-stream which recursively flattens streams of streams
Combine latest for pull streams