{"_id":"buffered-async-iterable","_rev":"4-bbd4410ceff7c4eb78f39643a2f0d5b2","name":"buffered-async-iterable","description":"Creates a prefetched async iterable","dist-tags":{"latest":"1.0.1"},"versions":{"0.1.0":{"name":"buffered-async-iterable","version":"0.1.0","keywords":[],"author":{"url":"http://kodfabrik.se/","name":"Pelle Wessman","email":"pelle@kodfabrik.se"},"license":"MIT","_id":"buffered-async-iterable@0.1.0","maintainers":[{"name":"voxpelli","email":"pelle@kodfabrik.se"}],"homepage":"http://github.com/voxpelli/buffered-async-iterable","bugs":{"url":"https://github.com/voxpelli/buffered-async-iterable/issues"},"dist":{"shasum":"17256ce1ef0aed8d2c61a74a36b03c15a1901fc5","tarball":"https://registry.npmjs.org/buffered-async-iterable/-/buffered-async-iterable-0.1.0.tgz","fileCount":18,"integrity":"sha512-yHTBCZsgUHhNob/BqR4TK8SmiBhgKpSm39mNd4+htBXJYkv6K/0lgqhbqqSOqDFXcpQuKaEYPGqcESOSYGgqsg==","signatures":[{"sig":"MEYCIQC0jABY+sVJx/b0cbhvb3VwHQ5tCsgKQtZW3ZGi+E5EYgIhAL7BsuJWt/uRIHn+NNdEThn9fFBAikmrqtOxSwfU36Qu","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":17969},"type":"module","types":"index.d.ts","engines":{"node":">=16.0.0"},"exports":"./index.js","gitHead":"b7aadbd51d4d3d3046dc5622e7c6b154b34cfaf7","scripts":{"test":"run-s check test:*","build":"run-s build:*","check":"run-s clean && run-p check:*","clean":"run-p clean:*","flame":"run-s flame:*","build:0":"run-s clean","prepare":"husky install","test-ci":"run-s test:*","benchmark":"run-s benchmark:*","check:tsc":"tsc","check:knip":"knip","check:lint":"eslint --report-unused-disable-directives .","flame:real":"run-s flame:real:*","test:mocha":"c8 --reporter=lcov --reporter text mocha 'test/**/*.spec.js'","flame:static":"run-s flame:static:*","prepublishOnly":"run-s build","benchmark:memory":"node --expose-gc benchmark/memory.js","clean:declarations":"rm -rf $(find . -maxdepth 2 -type f -name '*.d.ts*')","build:1-declaration":"tsc -p declaration.tsconfig.json","check:type-coverage":"type-coverage --detail --strict --at-least 95 --ignore-files 'benchmark/*' --ignore-files 'benchmark/*/*'","check:installed-check":"installed-check -i eslint-plugin-jsdoc -i knip","benchmark:event-loop-lag":"node benchmark/event-loop-lag.js","flame:real:event-loop-static":"0x -o -- node benchmark/event-loop-lag-real-static.js","flame:static:event-loop-static":"0x -o -- node benchmark/event-loop-lag-static.js","flame:real:event-loop-immediate":"0x -o -- node benchmark/event-loop-lag-real-immediate.js","flame:static:event-loop-immediate-all":"0x -o -- node benchmark/event-loop-lag-immediate-all.js","flame:static:event-loop-immediate-tenth":"0x -o -- node benchmark/event-loop-lag-immediate-tenth.js"},"_npmUser":{"name":"voxpelli","email":"pelle@kodfabrik.se"},"repository":{"url":"git://github.com/voxpelli/buffered-async-iterable.git","type":"git"},"_npmVersion":"9.6.6","description":"Creates a prefetched async iterable","directories":{},"_nodeVersion":"18.14.2","_hasShrinkwrap":false,"devDependencies":{"0x":"^5.5.0","c8":"^7.13.0","chai":"^4.3.7","knip":"^2.11.0","husky":"^8.0.3","mocha":"^10.2.0","sinon":"^15.1.0","eslint":"^8.40.0","sinon-chai":"^3.7.0","typescript":"~5.0.4","@types/chai":"^4.3.5","@types/node":"^16.18.31","@types/mocha":"^10.0.1","@types/sinon":"^10.0.15","npm-run-all2":"^6.0.5","type-coverage":"^2.25.3","eslint-plugin-n":"^16.0.0","installed-check":"^7.1.0","chai-as-promised":"^7.1.1","chai-quantifiers":"^1.0.17","@types/sinon-chai":"^3.2.9","@voxpelli/tsconfig":"^7.0.0","eslint-plugin-es-x":"^7.0.0","eslint-plugin-jsdoc":"^44.2.4","eslint-plugin-mocha":"^10.1.0","eslint-plugin-import":"^2.27.5","@airbnb/node-memwatch":"^2.0.0","eslint-plugin-promise":"^6.1.1","eslint-plugin-unicorn":"^47.0.0","eslint-plugin-security":"^1.7.1","@types/chai-as-promised":"^7.1.5","@types/chai-quantifiers":"^1.0.1","@voxpelli/eslint-config":"^17.0.3","@types/airbnb__node-memwatch":"^2.0.0","eslint-plugin-sort-destructure-keys":"^1.5.0"},"_npmOperationalInternal":{"tmp":"tmp/buffered-async-iterable_0.1.0_1684500156428_0.6556071398060355","host":"s3://npm-registry-packages"}},"0.2.0":{"name":"buffered-async-iterable","version":"0.2.0","keywords":[],"author":{"url":"http://kodfabrik.se/","name":"Pelle Wessman","email":"pelle@kodfabrik.se"},"license":"MIT","_id":"buffered-async-iterable@0.2.0","maintainers":[{"name":"voxpelli","email":"pelle@kodfabrik.se"}],"homepage":"http://github.com/voxpelli/buffered-async-iterable","bugs":{"url":"https://github.com/voxpelli/buffered-async-iterable/issues"},"dist":{"shasum":"4e8e0f7638b2d2aa3fbbe4301749876586dfe2b9","tarball":"https://registry.npmjs.org/buffered-async-iterable/-/buffered-async-iterable-0.2.0.tgz","fileCount":15,"integrity":"sha512-+y/R2r77xfW/W97YtP1/RI6+70sxiuQzjh1lHlYgKBdeFX/wd3N+d+aocyFFHipzMfwW3MTm2iZBsw1S9Bw5fA==","signatures":[{"sig":"MEYCIQCBFKKKbqwqmitGUR3WhYHg0gkPVjAa5cqxz3nJGQujvgIhALDludR3wCZPF4RCqXVYGhE3wM1UwyIPIcCqdeQgUaQY","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":19011},"type":"module","types":"index.d.ts","engines":{"node":">=16.0.0"},"exports":"./index.js","gitHead":"5898ef738710c2de255ab1d9cecf95e1f3a6d03c","scripts":{"test":"run-s check test:*","build":"run-s build:*","check":"run-s clean && run-p check:*","clean":"run-p clean:*","build:0":"run-s clean","prepare":"husky install","test-ci":"run-s test:*","check:tsc":"tsc","check:knip":"knip","check:lint":"eslint --report-unused-disable-directives .","test:mocha":"c8 --reporter=lcov --reporter text mocha 'test/**/*.spec.js'","prepublishOnly":"run-s build","clean:declarations":"rm -rf $(find . -maxdepth 2 -type f -name '*.d.ts*')","build:1-declaration":"tsc -p declaration.tsconfig.json","check:type-coverage":"type-coverage --detail --strict --at-least 95 --ignore-files 'test/*.spec.js'","check:installed-check":"installed-check -i eslint-plugin-jsdoc -i knip"},"_npmUser":{"name":"voxpelli","email":"pelle@kodfabrik.se"},"repository":{"url":"git://github.com/voxpelli/buffered-async-iterable.git","type":"git"},"_npmVersion":"9.6.7","description":"Creates a prefetched async iterable","directories":{},"_nodeVersion":"18.14.2","_hasShrinkwrap":false,"devDependencies":{"c8":"^7.13.0","chai":"^4.3.7","knip":"^2.11.0","husky":"^8.0.3","mocha":"^10.2.0","sinon":"^15.1.0","eslint":"^8.40.0","sinon-chai":"^3.7.0","typescript":"~5.0.4","@types/chai":"^4.3.5","@types/node":"^16.18.31","@types/mocha":"^10.0.1","@types/sinon":"^10.0.15","npm-run-all2":"^6.0.5","type-coverage":"^2.25.3","eslint-plugin-n":"^16.0.0","installed-check":"^7.1.0","chai-as-promised":"^7.1.1","chai-quantifiers":"^1.0.17","@types/sinon-chai":"^3.2.9","@voxpelli/tsconfig":"^7.0.0","eslint-plugin-es-x":"^7.0.0","eslint-plugin-jsdoc":"^44.2.4","eslint-plugin-mocha":"^10.1.0","eslint-plugin-import":"^2.27.5","eslint-plugin-promise":"^6.1.1","eslint-plugin-unicorn":"^47.0.0","eslint-plugin-security":"^1.7.1","@types/chai-as-promised":"^7.1.5","@types/chai-quantifiers":"^1.0.1","@voxpelli/eslint-config":"^17.0.3","eslint-plugin-sort-destructure-keys":"^1.5.0"},"_npmOperationalInternal":{"tmp":"tmp/buffered-async-iterable_0.2.0_1685374921036_0.9851926224828453","host":"s3://npm-registry-packages"}},"0.3.0":{"name":"buffered-async-iterable","version":"0.3.0","keywords":["async","iterator","highwatermark"],"author":{"url":"http://kodfabrik.se/","name":"Pelle Wessman","email":"pelle@kodfabrik.se"},"license":"MIT","_id":"buffered-async-iterable@0.3.0","maintainers":[{"name":"voxpelli","email":"pelle@kodfabrik.se"}],"homepage":"http://github.com/voxpelli/buffered-async-iterable","bugs":{"url":"https://github.com/voxpelli/buffered-async-iterable/issues"},"dist":{"shasum":"2808dabff88968d069a6f3efe316387d62cac8b9","tarball":"https://registry.npmjs.org/buffered-async-iterable/-/buffered-async-iterable-0.3.0.tgz","fileCount":15,"integrity":"sha512-McUDFN18nTngbI9EPqHXyifF3iReQtEeoCdukNtrypmPWMRxsJO6KbBihQ88PI+CIFhbCmm2cTkhgxmKADwFNA==","signatures":[{"sig":"MEYCIQDGj5ts59PYWbk+9bLcYLqXeHp78YYU5Wcuc9RtECOMzQIhAPos2IraoEe47QNReryownc3EUhQ4ps3x4C6oI/1Pb4j","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":19663},"type":"module","types":"index.d.ts","engines":{"node":">=18.6.0"},"exports":"./index.js","gitHead":"f77358b649574a98e4286668a6a1f5f41273a64c","scripts":{"test":"run-s check test:*","build":"run-s build:*","check":"run-s clean && run-p check:*","clean":"run-p clean:*","build:0":"run-s clean","prepare":"husky","test-ci":"run-s test:*","check:tsc":"tsc","check:knip":"knip","check:lint":"eslint --report-unused-disable-directives .","test:mocha":"c8 --reporter=lcov --reporter text mocha 'test/**/*.spec.js'","prepublishOnly":"run-s build","clean:declarations":"rm -rf $(find . -maxdepth 2 -type f -name '*.d.ts*')","build:1-declaration":"tsc -p declaration.tsconfig.json","check:type-coverage":"type-coverage --detail --strict --at-least 95 --ignore-files 'test/*.spec.js'","check:installed-check":"installed-check"},"_npmUser":{"name":"voxpelli","email":"pelle@kodfabrik.se"},"repository":{"url":"git://github.com/voxpelli/buffered-async-iterable.git","type":"git"},"_npmVersion":"10.5.0","description":"Creates a prefetched async iterable","directories":{},"_nodeVersion":"20.11.0","_hasShrinkwrap":false,"devDependencies":{"c8":"^9.1.0","chai":"^4.4.1","knip":"^5.1.1","husky":"^9.0.11","mocha":"^10.3.0","sinon":"^17.0.1","eslint":"^8.57.0","sinon-chai":"^3.7.0","typescript":"~5.4.2","@types/chai":"^4.3.12","@types/node":"^18.19.24","@types/mocha":"^10.0.6","@types/sinon":"^17.0.3","npm-run-all2":"^6.1.2","type-coverage":"^2.27.1","eslint-plugin-n":"^16.6.2","installed-check":"^8.0.1","chai-as-promised":"^7.1.1","chai-quantifiers":"^1.0.18","@types/sinon-chai":"^3.2.12","@voxpelli/tsconfig":"^11.0.0","eslint-plugin-es-x":"^7.5.0","eslint-plugin-jsdoc":"^46.10.1","eslint-plugin-mocha":"^10.4.1","eslint-plugin-import":"^2.29.1","eslint-plugin-promise":"^6.1.1","eslint-plugin-unicorn":"^48.0.1","eslint-plugin-security":"^1.7.1","@types/chai-as-promised":"^7.1.8","@types/chai-quantifiers":"^1.0.4","@voxpelli/eslint-config":"^19.0.0","eslint-plugin-sort-destructure-keys":"^1.5.0"},"_npmOperationalInternal":{"tmp":"tmp/buffered-async-iterable_0.3.0_1710680656080_0.18371465399165787","host":"s3://npm-registry-packages"}},"1.0.0":{"name":"buffered-async-iterable","version":"1.0.0","keywords":["async","iterator","highwatermark"],"author":{"url":"http://kodfabrik.se/","name":"Pelle Wessman","email":"pelle@kodfabrik.se"},"license":"MIT","_id":"buffered-async-iterable@1.0.0","maintainers":[{"name":"voxpelli","email":"pelle@kodfabrik.se"}],"homepage":"http://github.com/voxpelli/buffered-async-iterable","bugs":{"url":"https://github.com/voxpelli/buffered-async-iterable/issues"},"dist":{"shasum":"c8f7cdd03fcb542b82f8ff57e201d985ebcbf394","tarball":"https://registry.npmjs.org/buffered-async-iterable/-/buffered-async-iterable-1.0.0.tgz","fileCount":15,"integrity":"sha512-AR08Udej6Vz37PpHwlZEHQlAdjTOhQhcRirdMKwBDeN1hrGCVsBdbxT4oo9/iL52GcGrHZrJRRVfbl7BNAE+xQ==","signatures":[{"sig":"MEUCID3QeGGoQVOJTpCfzlzgNIDVZbaAjHeKSm1MUV5PVgrGAiEAlshd9MK5TDCOimfaEtwsk7GSVjUb+87aG+yWdlxobF8=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":21735},"type":"module","types":"index.d.ts","engines":{"node":">=18.6.0"},"exports":"./index.js","gitHead":"9e469b74e4bbed266e27600c09575f353b19b413","scripts":{"test":"run-s check test:*","build":"run-s build:*","check":"run-s clean && run-p check:*","clean":"run-p clean:*","build:0":"run-s clean","prepare":"husky","test-ci":"run-s test:*","check:tsc":"tsc","check:knip":"knip","check:lint":"eslint --report-unused-disable-directives .","test:mocha":"c8 --reporter=lcov --reporter text mocha 'test/**/*.spec.js'","prepublishOnly":"run-s build","clean:declarations":"rm -rf $(find . -maxdepth 2 -type f -name '*.d.ts*')","build:1-declaration":"tsc -p declaration.tsconfig.json","check:type-coverage":"type-coverage --detail --strict --at-least 95 --ignore-files 'test/*.spec.js'","check:installed-check":"installed-check"},"_npmUser":{"name":"voxpelli","email":"pelle@kodfabrik.se"},"repository":{"url":"git://github.com/voxpelli/buffered-async-iterable.git","type":"git"},"_npmVersion":"10.7.0","description":"Creates a prefetched async iterable","directories":{},"_nodeVersion":"20.12.2","_hasShrinkwrap":false,"devDependencies":{"c8":"^9.1.0","chai":"^4.4.1","knip":"^5.15.0","husky":"^9.0.11","mocha":"^10.4.0","sinon":"^17.0.1","eslint":"^8.57.0","sinon-chai":"^3.7.0","typescript":"~5.4.5","@types/chai":"^4.3.16","@types/node":"^18.19.24","@types/mocha":"^10.0.6","@types/sinon":"^17.0.3","npm-run-all2":"^6.1.2","type-coverage":"^2.28.2","eslint-plugin-n":"^16.6.2","installed-check":"^8.0.1","chai-as-promised":"^7.1.1","chai-quantifiers":"^1.0.18","@types/sinon-chai":"^3.2.12","@voxpelli/tsconfig":"^11.0.0","eslint-plugin-es-x":"^7.6.0","eslint-plugin-jsdoc":"^46.10.1","eslint-plugin-mocha":"^10.4.3","eslint-plugin-import":"^2.29.1","eslint-plugin-promise":"^6.1.1","eslint-plugin-unicorn":"^48.0.1","eslint-plugin-security":"^1.7.1","@types/chai-as-promised":"^7.1.8","@types/chai-quantifiers":"^1.0.4","@voxpelli/eslint-config":"^19.0.0","eslint-plugin-sort-destructure-keys":"^1.6.0"},"_npmOperationalInternal":{"tmp":"tmp/buffered-async-iterable_1.0.0_1715514404369_0.9988412913115374","host":"s3://npm-registry-packages"}},"1.0.1":{"name":"buffered-async-iterable","version":"1.0.1","description":"Creates a prefetched async iterable","homepage":"http://github.com/voxpelli/buffered-async-iterable","repository":{"type":"git","url":"git://github.com/voxpelli/buffered-async-iterable.git"},"keywords":["async","iterator","highwatermark"],"author":{"name":"Pelle Wessman","email":"pelle@kodfabrik.se","url":"http://kodfabrik.se/"},"license":"MIT","engines":{"node":">=18.6.0"},"type":"module","exports":"./index.js","types":"index.d.ts","scripts":{"build:0":"run-s clean","build:1-declaration":"tsc -p declaration.tsconfig.json","build":"run-s build:*","check:installed-check":"installed-check -i @voxpelli/eslint-config -i eslint","check:knip":"knip","check:lint":"eslint --report-unused-disable-directives .","check:tsc":"tsc","check:type-coverage":"type-coverage --detail --strict --at-least 95 --ignore-files 'test/*.spec.js'","check":"run-s clean && run-p check:*","clean:declarations":"rm -rf $(find . -maxdepth 2 -type f -name '*.d.ts*')","clean":"run-p clean:*","prepare":"husky","prepublishOnly":"run-s build","test:mocha":"c8 --reporter=lcov --reporter text mocha 'test/**/*.spec.js'","test-ci":"run-s test:*","test":"run-s check test:*"},"devDependencies":{"@types/chai":"^4.3.16","@types/chai-as-promised":"^7.1.8","@types/chai-quantifiers":"^1.0.4","@types/mocha":"^10.0.7","@types/node":"^18.19.39","@types/sinon":"^17.0.3","@types/sinon-chai":"^3.2.12","@voxpelli/eslint-config":"^20.0.0-beta.3","@voxpelli/tsconfig":"^12.0.1","c8":"^10.1.2","chai":"^4.4.1","chai-as-promised":"^7.1.1","chai-quantifiers":"^1.0.18","eslint":"^9.5.0","husky":"^9.0.11","installed-check":"^9.3.0","knip":"^5.22.3","mocha":"^10.5.0","npm-run-all2":"^6.2.0","sinon":"^18.0.0","sinon-chai":"^3.7.0","type-coverage":"^2.29.0","typescript":"~5.5.2","validate-conventional-commit":"^1.0.3"},"_id":"buffered-async-iterable@1.0.1","gitHead":"4c364643a98744e93c92ff3bb88fa4f7f93437e0","bugs":{"url":"https://github.com/voxpelli/buffered-async-iterable/issues"},"_nodeVersion":"20.14.0","_npmVersion":"10.8.1","dist":{"integrity":"sha512-QqoUm0XP17Bu6zzyvpK92K7jNYMoFYgKM0ZKr0OkoDlElpTTeucGmdJL8I7W+reFIfvgUWOm1PgJC+OxM2lMEQ==","shasum":"9d856d345f7c44546ffc440c013340bd2903cf69","tarball":"https://registry.npmjs.org/buffered-async-iterable/-/buffered-async-iterable-1.0.1.tgz","fileCount":15,"unpackedSize":22239,"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/buffered-async-iterable@1.0.1","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIBdq1wIOG2r6CS45gMjm1D0Sx1FtG2rj2J/gjgqvKmvsAiEArp7n47/7PyJ1kTFUBrI0K003JWXb7kOIVR9QUZuNWPw="}]},"_npmUser":{"name":"voxpelli","email":"pelle@kodfabrik.se"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/buffered-async-iterable_1.0.1_1719260734593_0.7241489029582753"},"_hasShrinkwrap":false}},"time":{"created":"2023-05-19T12:42:36.427Z","modified":"2024-06-24T20:25:35.166Z","0.1.0":"2023-05-19T12:42:36.635Z","0.2.0":"2023-05-29T15:42:01.242Z","0.3.0":"2024-03-17T13:04:16.248Z","1.0.0":"2024-05-12T11:46:44.493Z","1.0.1":"2024-06-24T20:25:34.752Z"},"maintainers":[{"name":"voxpelli","email":"pelle@kodfabrik.se"}],"author":{"name":"Pelle Wessman","email":"pelle@kodfabrik.se","url":"http://kodfabrik.se/"},"repository":{"type":"git","url":"git://github.com/voxpelli/buffered-async-iterable.git"},"keywords":["async","iterator","highwatermark"],"license":"MIT","homepage":"http://github.com/voxpelli/buffered-async-iterable","bugs":{"url":"https://github.com/voxpelli/buffered-async-iterable/issues"},"readme":"
\n \n
\n\n\nBuffered parallel processing of async iterables / generators.\n\n[![npm version](https://img.shields.io/npm/v/buffered-async-iterable.svg?style=flat)](https://www.npmjs.com/package/buffered-async-iterable)\n[![npm downloads](https://img.shields.io/npm/dm/buffered-async-iterable.svg?style=flat)](https://www.npmjs.com/package/buffered-async-iterable)\n[![Module type: ESM](https://img.shields.io/badge/module%20type-esm-brightgreen)](https://github.com/voxpelli/badges-cjs-esm)\n[![Types in JS](https://img.shields.io/badge/types_in_js-yes-brightgreen)](https://github.com/voxpelli/types-in-js)\n[![neostandard javascript style](https://img.shields.io/badge/code_style-neostandard-7fffff?style=flat&labelColor=ff80ff)](https://github.com/neostandard/neostandard)\n[![Follow @voxpelli@mastodon.social](https://img.shields.io/mastodon/follow/109247025527949675?domain=https%3A%2F%2Fmastodon.social&style=social)](https://mastodon.social/@voxpelli)\n\n\n## Usage\n\n### Simple\n\n```javascript\nimport { bufferedAsyncMap } from 'buffered-async-iterable';\n\nasync function * asyncGenerator() {\n yield ...\n}\n\nconst mappedIterator = bufferedAsyncMap(asyncGenerator(), async (item) => {\n // Apply additional async lookup / processing\n});\n\nfor await (const item of mappedIterator) {\n // Consume the buffered async iterable\n}\n```\n\n### Array input\n\n```javascript\nimport { bufferedAsyncMap } from 'buffered-async-iterable';\n\nconst mappedIterator = bufferedAsyncMap(['foo'], async (item) => {\n // Apply additional async lookup / processing\n});\n\nfor await (const item of mappedIterator) {\n // Consume the buffered async iterable\n}\n```\n\n### Async generator result\n\n```javascript\nimport { bufferedAsyncMap } from 'buffered-async-iterable';\n\nconst mappedIterator = bufferedAsyncMap(['foo'], async function * (item) => {\n // Apply additional async lookup / processing\n yield ...\n yield * ...\n});\n\nfor await (const item of mappedIterator) {\n // Consume the buffered async iterable\n}\n```\n\n## API\n\n### bufferedAsyncMap()\n\nIterates and applies the `callback` to up to `bufferSize` items from `input` yielding values as they resolve.\n\n#### Syntax\n\n`bufferedAsyncMap(input, callback[, { bufferSize=6, ordered=false }]) => AsyncIterableIterator`\n\n#### Arguments\n\n* `input` – either an async iterable, an ordinare iterable or an array\n* `callback(item)` – should be either an async generator or an ordinary async function. Items from async generators are buffered in the main buffer and the buffer is refilled by the one that has least items in the current buffer (`input` is considered equal to sub iterators in this regard when refilling the buffer)\n\n#### Options\n\n* `bufferSize` – _optional_ – defaults to `6`, sets the max amount of simultanoeus items that processed at once in the buffer.\n* `ordered` – _optional_ – defaults to `false`, when `true` the result will be returned in order instead of unordered\n\n### mergeIterables()\n\nMerges all given (async) iterables in parallel, returning the values as they resolve\n\n#### Syntax\n\n`mergeIterables(input[, { bufferSize=6 }]) => AsyncIterableIterator`\n\n#### Arguments\n\n* `input` – an array of async iterables, ordinare iterables and/or arrays\n\n#### Options\n\n* `bufferSize` – _optional_ – defaults to `6`, sets the max amount of simultanoeus items that processed at once in the buffer.\n\n## Similar modules\n\n* [`hwp`](https://github.com/mcollina/hwp) – similar module by [@mcollina](https://github.com/mcollina)\n\n\n","readmeFilename":"README.md"}