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-ndjson-stream Read and write ndjson messages over a duplex stream
• 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-queueless-pushable A pushable queue that waits until a value is consumed before accepting another
• packages/it-reduce Reduces the values yielded from an async iterator
• packages/it-rpc Schema-free RPC over async iterables
• 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 together

• https://achingbrain.github.io/it

Licensed under either of

• Apache 2.0, (LICENSE-APACHE / http://www.apache.org/licenses/LICENSE-2.0)
• MIT (LICENSE-MIT / http://opensource.org/licenses/MIT)

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.