Useful modules for working with async iterables:
abortable-iterator
- Make any iterator or iterable abortable via an AbortSignalasync-iterator-all
- Collects all values from an async iterator and returns them as an arrayasync-iterator-batch
- Takes an async iterator that emits variable length arrays and emits them as fixed size batchesasync-iterator-buffer-stream
- An async iterator that emits buffers containing bytes up to a certain lengthasync-iterator-first
- Returns the first result from an async iteratorasync-iterator-last
- Returns the last result from an async iteratorasync-iterator-to-buffer
- When passed an async iterator that returns buffers, cat them all togetherasync-iterator-to-pull-stream
- Convert a (async) iterator to a pull streamemitterator
- Convert async iterator to event emitterevent-iterator
- Convert event emitter to async iteratorget-iterator
- Get the default iterator or async iterator for an Iterableit-block
- Transform input into equally-sized blocks of outputit-glob
- Async iterable filename pattern matcherit-goodbye
- Add a goodbye handshake to a duplex async iterableit-keepalive
- Keep an async iterable alive by yielding a value if it doesn't yield a value before the timeoutit-length-prefixed
- Streaming length prefixed buffers with async iterablesit-multipart
- HTTP multipart message parserit-pair
- A pair of {source, sink} streams that are internally connected (what goes into the sink comes out the source)it-pipe
- Utility to "pipe" async iterables togetherit-pushable
- Pushable iterableit-reader
- Read an exact number of bytes from a binary (async) iterableit-tar
- Streaming tar parser (and maybe a generator in the future) and nothing elseit-to-stream
- Convert streaming iterables to Node.js streamsit-ws
- Simple async iterators for websocket client and server connectionsiterable-ndjson
- NDJSON parsing/encodingparamap-it
- Parallel mapping for async iterablespull-stream-to-async-iterator
- Convert a pull stream to an async iteratorrecoverable-iterator
- If an iterator errors, restart and continuestream-to-it
- Convert Node.js streams to streaming iterablesstreaming-iterables
- A Swiss army knife for async iterablesiter-tools
- The iterable toolbox