JSPM

unwind the stack while reading recursively from a pull-stream

Simple pull-streams for websocket client connections

Convert a pull-stream into a thenable

Transform arrays of objects into arrays with a maximum length

Pull streams implementation of a file reader

Like pull.drain, but respects CPU load

Convert a pull-stream to an Async Iterable

Simple pull-streams for websocket client connections

Catch errors in a pull stream

Streaming length prefixed buffers with pull-streams

a through for dominictarr's pull-stream to remove items with an async filter function

Combine latest for pull streams

Flat map for pull streams

Scan algorithm for pull streams

Helpers for working with pull streams

Identify the type of file passing through the stream

Combine a stream with the latest value from another stream

Pull Streams for socket.io

A pull-streams ndjson parser and serializer, inspired by and compatible with [ndjson](https://www.npmjs.com/package/ndjson).

pull-stream throughs for manipulating (splitting, etc) buffers

transform input into equally-sized blocks of output

libsodium secretstream as a pull stream

A pull-stream that filters until X elements, and stops streaming after Y elements.

Pull streams over window.postMessage

a through for dominictarr's pull-stream to delay the inputs

pull-stream source that produces data on state transitions

simple composable data services using muxrpc

Protocol Buffers length-prefixed pull-stream encoder/decoder

Fast, simple data pipelines

use pull-streams to make gitremote-helpers(1)

cache a pull-stream

IndexedDB implementation for interface-pull-blob-store

Test suite for pull-blob-stores

read buffered data from a pull-stream

Test suite for pull-blob-stores

websockets with pull-streams, like websocket-stream but much leaner

a pull-stream interface for the `require('nets')` npm module

Namespace streams

An infinite scroller fed by pull-streams

Limits the total number of items inside a through pull-stream.

This is designed to work with stepping queries in [ssb-query](https://github.com/dominictarr/ssb-query) (a scuttlebot plugin).

Create a duplex stream from a preact component

Map Pull Stream with Promise support and done callback

High level router using pull streams

pull-stream based library

State machine as a pull stream

abstract git repo interface using pull streams

minimalistic html tree widget using hyperscript, hyperobj and pull-streams

Logs synchronization events inside a pull-stream.

Create a broadcast pull-stream.

data event streams made easy, built on top of PipeStreams, which is built on top of pull-stream

Read source pull-streams, in round robin fashion.

Load Balancer for through pull streams.

Transform pipeline operator into pull(...) calls

Pull-stream file and path helpers

Simple pull-stream for DOM events

Stdio functions for pull streams.

pull-stream source and sink for WebRTC data channels

Redirectable pull-streams

Async Map Pull Stream with Done callback

Bundles your project together with pull-stream

Protocol Buffers RPC utility module for pull-streams

Get meta-data of all repositories by a specific organisation as a pull-stream

LevelDB implementation for interface-pull-blob-store

Spawn pull streams into substreams.

Control flow for pull streams.

Use this pull-stream to lazily traverse a paginated (REST) API!

Pull stream with queue

Buffer that reads (enqueue) as much data as possible before draining (dequeuing).

Catch abort events in pull streams

Sink ssb-review streams into mutant arrays

Clone a pull-stream manually.

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)

get a meta-data pull-stream of all videos a user liked on youtube (browser & node)

Consume the flickr API (search at this stage) with pull-streams

MessagePack as pull-stream

Pull the value from a promise using pull-streams

Unwind/flatten a complex stream to a simpler one.

Server-sent events magic for pull-streams

A through stream that does CPU throttling to avoid full CPU usage

Wrap handlers to use pull-stream

JSON pull through stream

pull-stream through, like flat-map but with inner cancellation

Bundle JS files inside pull-stream with Browserify

Match routes with a pull stream

Turn your view into a duplex stream

Create a duplex stream from a react component.

hyperscript as a pull-stream source. Allows streaming the view to the browser as it continues to render.

Pull all of npm's metadata

A pullstream "webdriver" for interacting with changes to the dom.

Create an html file from js and css file streams

A pull-stream through that will throttle the source until a Pixi.js sprite event happens

a pull-stream source that generates an infinite number of ticks

pull-stream implementation based on generators.

Chaining for pull-stream functions

throttle a pull stream

Create a duplex stream from a react component.

A refinement of the parallel map module for dynamic, unbounded, and fault-tolerant parallel processing.

MessagePack v5 as pull-stream

Synchronizes pull-streams that are connected by an unsynchronized transport.

Concat pull-stream files into one

Converts a pull-stream duplex into a net.Socket

Split a stream into other streams using filters

A dom render loop using picodom and pull streams

pull-stream that performs cartesian multiplication on json objects.

observable as a pull-stream source to take advantage of existing throughs and sinks

Converts a pull-stream function into an equivalent object form.

A state machine with pull stream interface

read WARC file records as a pull-stream

pull-stream utilities

Browserify functions for pull stream

requestIdleCallback pull through

A pull-stream through that will throttle the source until the next tick of a Pixi.js ticker

Convert a promise to a pull-stream

A source that masks other sources over its lifetime.

File system functions with a separated metadata system.

Pull stream for UI keydown events

Fetch function for pull stream

Minify JavaScript files or buffers inside a pull-stream

Pull stream of authenticated encryption ChaCha20-Poly1305

Timeout pull streams.

Drain a pull-stream and await the result

Collate json objects and send them downstream.

Like pull-stream's unique through stream but requires a result to be present in all streams

Select a property and replace inside an object

Produces a stream from the pull-stream protocol events happening during the interaction between two modules.

Http pull-stream functions

Create a pull stream from an async function call

Use pull-streams with child_process.spawn stdio

Lightweight multiplexing for pull streams

Collect items into batches for optimal write operations to leveldb

pull-stream for cross-domain inter-frame communication using postMessage

Collate array objects and send them downstream.

Multiple execution contexts for pull substreams.

A through stream that runs a user-provided, untrusted mapper function in a quickjs sandbox in a worker thread.

debouncing pull-stream

a tiny lib for patchcore stream stepping

uuid generation as an infinite pull stream

Read and write `Vinyl` objects in the file system.

Lends one value at a time from a stream. Re-lends in case of errors.

a stream-to-pull-stream written in typescript

source stream interface to recvfrom

[].reduce()-esque pull-stream sinks

GRPC pull stream interface

Pull-stream which recursively flattens streams of streams

Uglify JavaScript files with pull-stream

cache a pull-stream so it can be read in reverse

Observ struct instance from a pull stream

streamdata.io server-sent events as a pull-stream source

Read from an alternative source, if the main ended.

Map pull-stream errors.

raf as a through pull stream

A simple library for composable DOM elements using tagged template strings.

Parse CSS into ASTs through a pull stream, or vice versa.

parse strings into emoji through a pull-stream interface

Minimal express-like router for pull-streams

abort a pull-stream if the rate of flow drops below the specified threshold.

Minify JS and CSS files inside a pull-stream

This is an ES module build of [pull-stream](https://github.com/pull-stream/pull-stream)

Replay a pull-stream on demand.

Create sync, async, or through maps in pull-streams

Pull-streams for reading and writing in CouchDB.

Tests for pull streams

Pull-stream sink that collects values into an array then returns a promise.

Group items and reduce each group to a single value

tre-image-size ---

Group items and reduce each group to a single value

Keeps resubmitting inputs to transformer until the corresponding outputs test successfully.

pull-stream source for exponential backoff intervals

A push-stream through that applies backpressure when CPU is too busy

Like pull.through, but taps into requests, not responses

Drain pull-stream and return a promise

pull-stream that groups items by return value of a user-defined function