JSPM

Pull streams implementation of a file reader

Transform arrays of objects into arrays with a maximum length

unwind the stack while reading recursively from a pull-stream

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

Simple pull-streams for websocket client connections

Catch errors in a pull stream

Streaming length prefixed buffers with pull-streams

Simple pull-streams for websocket client connections

Convert a pull-stream into a thenable

transform input into equally-sized blocks of output

Like pull.drain, but respects CPU load

Convert a pull-stream to an Async Iterable

Pull Streams for socket.io

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 remove items with an async filter function

Scan algorithm for pull streams

Test suite for pull-blob-stores

Helpers for working with pull streams

IndexedDB implementation for interface-pull-blob-store

Combine latest for pull streams

Flat map for pull streams

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

Combine a stream with the latest value from another stream

Test suite for pull-blob-stores

libsodium secretstream as a pull stream

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

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

pull-stream source that produces data on state transitions

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

simple composable data services using muxrpc

Protocol Buffers length-prefixed pull-stream encoder/decoder

pull-stream based library

Pull the value from a promise using pull-streams

Namespace streams

cache a pull-stream

Async Map Pull Stream with Done callback

Fast, simple data pipelines

An infinite scroller fed by pull-streams

Identify the type of file passing through the stream

Logs synchronization events inside a pull-stream.

Map Pull Stream with Promise support and done callback

Split a stream into other streams using filters

read buffered data from a pull-stream

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

Sink ssb-review streams into mutant arrays

debouncing pull-stream

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

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

Select a property and replace inside an object

Lightweight multiplexing for pull streams

Match routes with a pull stream

Minify JavaScript files or buffers inside a pull-stream

Server-sent events magic for pull-streams

Pull stream with queue

State machine as a pull stream

Redirectable pull-streams

MessagePack v5 as pull-stream

Converts a pull-stream duplex into a net.Socket

High level router using pull streams

Tests for pull streams

Unwind/flatten a complex stream to a simpler one.

a stream-to-pull-stream written in typescript

Drain a pull-stream and await the result

Control flow for pull streams.

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

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

Catch abort events in pull streams

Read from an alternative source, if the main ended.

Create a pull stream from an async function call

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

Create a broadcast pull-stream.

Timeout pull streams.

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

Pull stream of authenticated encryption ChaCha20-Poly1305

Concat pull-stream files into one

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

Fetch function for pull stream

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)

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

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

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

A state machine with pull stream interface

Load Balancer for through pull streams.

Stdio functions for pull streams.

A source that masks other sources over its lifetime.

Pull stream for UI keydown events

Create a duplex stream from a preact component

Clone a pull-stream manually.

Protocol Buffers RPC utility module for pull-streams

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

Spawn pull streams into substreams.

Wrap handlers to use pull-stream

pull-stream implementation based on generators.

Use pull-streams with child_process.spawn stdio

Create a duplex stream from a react component.

Map pull-stream errors.

Turn your view into a duplex stream

Pull-stream file and path helpers

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

Replay a pull-stream on demand.

Observ struct instance from a pull stream

tre-image-size ---

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

Convert a promise to a pull-stream

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

Read source pull-streams, in round robin fashion.

abstract git repo interface using pull streams

Browserify functions for pull stream

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

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

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

pull-stream that performs cartesian multiplication on json objects.

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

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

Minify JS and CSS files inside a pull-stream

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

Http pull-stream functions

Pull-streams for reading and writing in CouchDB.

Multiple execution contexts for pull substreams.

Collate json objects and send them downstream.

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

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

Minimal express-like router for pull-streams

LevelDB implementation for interface-pull-blob-store

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

pull-stream utilities

Collate array objects and send them downstream.

Bundle JS files inside pull-stream with Browserify

pull-stream source and sink for WebRTC data channels

Group items and reduce each group to a single value

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

source stream interface to recvfrom

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

Pull all of npm's metadata

MessagePack as pull-stream

Uglify JavaScript files with pull-stream

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

throttle a pull stream

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

Simple pull-stream for DOM events

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

Bundles your project together with pull-stream

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

Pull-stream which recursively flattens streams of streams

Create a duplex stream from a react component.

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

Drain pull-stream and return a promise

uuid generation as an infinite pull stream

read WARC file records as a pull-stream

Chaining for pull-stream functions

Transform pipeline operator into pull(...) calls

a tiny lib for patchcore stream stepping

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

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

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

Collect items into batches for optimal write operations to leveldb

JSON pull through stream

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

pull-stream source for exponential backoff intervals

A dom render loop using picodom and pull streams

Group items and reduce each group to a single value

GRPC pull stream interface

parse strings into emoji through a pull-stream interface

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

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

requestIdleCallback pull through

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

raf as a through pull stream

File system functions with a separated metadata system.

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

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