A collection of utilities for making working with iterables more bearable
packages/blob-to-itTurns a blob into an async iteratorpackages/browser-readablestream-to-itTurns a browser readble stream into an async iteratorpackages/it-allCollects all values from an (async) iterable and returns them as an arraypackages/it-batchTakes an async iterator that emits things and emits them as fixed size batchespackages/it-batched-bytesTakes an async iterator that emits byte arrays and emits them as fixed size batchespackages/it-buffer-streamAn async iterator that emits buffers containing bytes up to a certain lengthpackages/it-byte-streamRead and write arbitrary bytes over a duplex streampackages/it-cbor-streamRead and write CBOR messages over a duplex streampackages/it-drainEmpties an async iteratorpackages/it-filterFilters the passed iterable by using the filter functionpackages/it-firstReturns the first result from an async iteratorpackages/it-flat-batchTakes an async iterator that emits variable length arrays and emits them as fixed size batchespackages/it-foreachInvokes the passed function for each item in an iterablepackages/it-globAsync iterable filename pattern matcherpackages/it-lastReturns the last result from an async iteratorpackages/it-lengthCounts the number of items in an async iterablepackages/it-length-prefixed-streamRead and write length-prefixed byte arrays over a duplex streampackages/it-limit-bytesLimit the number of bytes that are yielded from an (async) iterablepackages/it-mapMaps the values yielded by an async iteratorpackages/it-mergeTreat one or more iterables as a single iterablepackages/it-multipartAsync iterable http multipart message parserpackages/it-ndjsonParse iterators as ndjson and transform iterators to ndjsonpackages/it-ndjson-streamRead and write ndjson messages over a duplex streampackages/it-parallelProcess incoming async(iterable) functions in parallelpackages/it-parallel-batchProcess (async)iterable values as functions with concurrency controlpackages/it-peekableAllows peeking/pushing an iterablepackages/it-protobuf-streamRead and write protobuf messages over a duplex streampackages/it-queueA queue implementation that can be iterated overpackages/it-queueless-pushableA pushable queue that waits until a value is consumed before accepting anotherpackages/it-reduceReduces the values yielded from an async iteratorpackages/it-rpcSchema-free RPC over async iterablespackages/it-skipSkip items from an iterablepackages/it-sortCollects all values from an async iterator, sorts them using the passed function and yields thempackages/it-splitSplits Uint8Arrays emitted by an (async) iterable by a delimiterpackages/it-takeStop iteration after n items have been receivedpackages/it-to-browser-readablestreamTakes an async iterator and turns it into a browser readable streampackages/it-to-bufferTakes an async iterator that yields buffers and concatenates them all together
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.