A collection of utilities for making working with iterables more bearable
TypeScript
284
839 commits
updated Sep 22, 2026
A collection of utilities for making working with iterables more bearable
packages/blob-to-it Turns a blob into an async iteratorpackages/browser-readablestream-to-it Turns a browser readble stream into an async iteratorpackages/it-all Collects all values from an (async) iterable and returns them as an arraypackages/it-batch Takes an async iterator that emits things and emits them as fixed size batchespackages/it-batched-bytes Takes an async iterator that emits byte arrays and emits them as fixed size batchespackages/it-buffer-stream An async iterator that emits buffers containing bytes up to a certain lengthpackages/it-byte-stream Read and write arbitrary bytes over a duplex streampackages/it-cbor-stream Read and write CBOR messages over a duplex streampackages/it-drain Empties an async iteratorpackages/it-filter Filters the passed iterable by using the filter functionpackages/it-first Returns the first result from an async iteratorpackages/it-flat-batch Takes an async iterator that emits variable length arrays and emits them as fixed size batchespackages/it-foreach Invokes the passed function for each item in an iterablepackages/it-glob Async iterable filename pattern matcherpackages/it-last Returns the last result from an async iteratorpackages/it-length Counts the number of items in an async iterablepackages/it-length-prefixed-stream Read and write length-prefixed byte arrays over a duplex streampackages/it-limit-bytes Limit the number of bytes that are yielded from an (async) iterablepackages/it-map Maps the values yielded by an async iteratorpackages/it-merge Treat one or more iterables as a single iterablepackages/it-multipart Async iterable http multipart message parserpackages/it-ndjson Parse iterators as ndjson and transform iterators to ndjsonpackages/it-ndjson-stream Read and write ndjson messages over a duplex streampackages/it-parallel Process incoming async(iterable) functions in parallelpackages/it-parallel-batch Process (async)iterable values as functions with concurrency controlpackages/it-peekable Allows peeking/pushing an iterablepackages/it-protobuf-stream Read and write protobuf messages over a duplex streampackages/it-queue A queue implementation that can be iterated overpackages/it-queueless-pushable A pushable queue that waits until a value is consumed before accepting anotherpackages/it-reduce Reduces the values yielded from an async iteratorpackages/it-rpc Schema-free RPC over async iterablespackages/it-skip Skip items from an iterablepackages/it-sort Collects all values from an async iterator, sorts them using the passed function and yields thempackages/it-split Splits Uint8Arrays emitted by an (async) iterable by a delimiterpackages/it-take Stop iteration after n items have been receivedpackages/it-to-browser-readablestream Takes an async iterator and turns it into a browser readable streampackages/it-to-buffer Takes an async iterator that yields buffers and concatenates them all togetherLicensed under either of
Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.
5,096 followers · starred Dec 2019
515 followers · starred May 2020
643 followers · starred May 2023
602 followers · starred Jan 2020
A collection of utilities for making working with iterables more bearable
TypeScript
284
839 commits
updated Sep 22, 2026
A collection of utilities for making working with iterables more bearable
packages/blob-to-it Turns a blob into an async iteratorpackages/browser-readablestream-to-it Turns a browser readble stream into an async iteratorpackages/it-all Collects all values from an (async) iterable and returns them as an arraypackages/it-batch Takes an async iterator that emits things and emits them as fixed size batchespackages/it-batched-bytes Takes an async iterator that emits byte arrays and emits them as fixed size batchespackages/it-buffer-stream An async iterator that emits buffers containing bytes up to a certain lengthpackages/it-byte-stream Read and write arbitrary bytes over a duplex streampackages/it-cbor-stream Read and write CBOR messages over a duplex streampackages/it-drain Empties an async iteratorpackages/it-filter Filters the passed iterable by using the filter functionpackages/it-first Returns the first result from an async iteratorpackages/it-flat-batch Takes an async iterator that emits variable length arrays and emits them as fixed size batchespackages/it-foreach Invokes the passed function for each item in an iterablepackages/it-glob Async iterable filename pattern matcherpackages/it-last Returns the last result from an async iteratorpackages/it-length Counts the number of items in an async iterablepackages/it-length-prefixed-stream Read and write length-prefixed byte arrays over a duplex streampackages/it-limit-bytes Limit the number of bytes that are yielded from an (async) iterablepackages/it-map Maps the values yielded by an async iteratorpackages/it-merge Treat one or more iterables as a single iterablepackages/it-multipart Async iterable http multipart message parserpackages/it-ndjson Parse iterators as ndjson and transform iterators to ndjsonpackages/it-ndjson-stream Read and write ndjson messages over a duplex streampackages/it-parallel Process incoming async(iterable) functions in parallelpackages/it-parallel-batch Process (async)iterable values as functions with concurrency controlpackages/it-peekable Allows peeking/pushing an iterablepackages/it-protobuf-stream Read and write protobuf messages over a duplex streampackages/it-queue A queue implementation that can be iterated overpackages/it-queueless-pushable A pushable queue that waits until a value is consumed before accepting anotherpackages/it-reduce Reduces the values yielded from an async iteratorpackages/it-rpc Schema-free RPC over async iterablespackages/it-skip Skip items from an iterablepackages/it-sort Collects all values from an async iterator, sorts them using the passed function and yields thempackages/it-split Splits Uint8Arrays emitted by an (async) iterable by a delimiterpackages/it-take Stop iteration after n items have been receivedpackages/it-to-browser-readablestream Takes an async iterator and turns it into a browser readable streampackages/it-to-buffer Takes an async iterator that yields buffers and concatenates them all togetherLicensed under either of
Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.
5,096 followers · starred Dec 2019
515 followers · starred May 2020
643 followers · starred May 2023
602 followers · starred Jan 2020