A collection of utilities for making working with iterables more bearable
/packages/blob-to-it
Turns a blob into an async iterator/packages/browser-readablestream-to-it
Turns a browser readble stream into an async iterator/packages/it-all
Collects all values from an (async) iterable and returns them as an array/packages/it-batch
Takes an async iterator that emits things and emits them as fixed size batches/packages/it-batched-bytes
Takes an async iterator that emits byte arrays and emits them as fixed size batches/packages/it-buffer-stream
An async iterator that emits buffers containing bytes up to a certain length/packages/it-byte-stream
Read and write arbitrary bytes over a duplex stream/packages/it-drain
Empties an async iterator/packages/it-filter
Filters the passed iterable by using the filter function/packages/it-first
Returns the first result from an async iterator/packages/it-flat-batch
Takes an async iterator that emits variable length arrays and emits them as fixed size batches/packages/it-foreach
Invokes the passed function for each item in an iterable/packages/it-glob
Async iterable filename pattern matcher/packages/it-last
Returns the last result from an async iterator/packages/it-length
Counts the number of items in an async iterable/packages/it-length-prefixed-stream
Read and write length-prefixed byte arrays over a duplex stream/packages/it-map
Maps the values yielded by an async iterator/packages/it-merge
Treat one or more iterables as a single iterable/packages/it-multipart
Async iterable http multipart message parser/packages/it-ndjson
Parse iterators as ndjson and transform iterators to ndjson/packages/it-parallel
Process incoming async(iterable) functions in parallel/packages/it-parallel-batch
Process (async)iterable values as functions with concurrency control/packages/it-peekable
Allows peeking/pushing an iterable/packages/it-protobuf-stream
Read and write protobuf messages over a duplex stream/packages/it-reduce
Reduces the values yielded from an async iterator/packages/it-skip
Skip items from an iterable/packages/it-sort
Collects all values from an async iterator, sorts them using the passed function and yields them/packages/it-split
Splits Uint8Arrays emitted by an (async) iterable by a delimiter/packages/it-take
Stop iteration after n items have been received/packages/it-to-browser-readablestream
Takes an async iterator and turns it into a browser readable stream/packages/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.