{"_id":"tiny-async-pool","_rev":"4245039","name":"tiny-async-pool","description":"Run multiple promise-returning & async functions with limited concurrency using native ES9","dist-tags":{"latest":"2.1.0"},"maintainers":[{"name":"rxaviers","email":""}],"time":{"modified":"2026-03-29T21:30:07.000Z","created":"2018-06-25T08:15:12.281Z","2.1.0":"2022-05-10T11:07:33.475Z","2.0.1":"2022-03-20T12:35:41.213Z","2.0.0":"2022-03-18T13:09:08.997Z","1.3.0":"2022-03-18T12:54:13.079Z","1.2.0":"2020-10-28T00:18:20.464Z","1.1.0":"2019-11-27T13:40:17.775Z","1.0.4":"2018-10-26T19:34:14.553Z","1.0.3":"2018-10-24T18:18:57.135Z","1.0.2":"2018-10-23T13:48:47.639Z","1.0.1":"2018-07-03T20:50:56.150Z","1.0.0":"2018-06-25T08:15:12.281Z"},"users":{},"author":{"name":"Rafael Xavier de Souza"},"repository":{"type":"git","url":"git+ssh://git@github.com/rxaviers/async-pool.git"},"versions":{"2.1.0":{"name":"tiny-async-pool","version":"2.1.0","description":"Run multiple promise-returning & async functions with limited concurrency using native ES9","main":"lib/es9.js","scripts":{"prettier":"prettier --write '{lib,test}/**/*.js'","test":"eslint lib && NODE_ENV=development mocha"},"repository":{"type":"git","url":"git+ssh://git@github.com/rxaviers/async-pool.git"},"keywords":["race","concurrency","promise","async","async iterator","async iteration","async generator","es9"],"author":{"name":"Rafael Xavier de Souza"},"license":"MIT","devDependencies":{"babel-eslint":"^10.1.0","chai":"^4.1.2","chai-as-promised":"^7.1.1","eslint":"^4.17.0","eslint-config-prettier":"^2.9.0","eslint-plugin-prettier":"^2.6.0","mocha":"^5.0.0","prettier":"^1.10.2"},"dependencies":{},"gitHead":"770c4574ecd9024965a0834e4c5ef606b67ea666","bugs":{"url":"https://github.com/rxaviers/async-pool/issues"},"homepage":"https://github.com/rxaviers/async-pool#readme","_id":"tiny-async-pool@2.1.0","_nodeVersion":"15.14.0","_npmVersion":"7.7.6","dist":{"shasum":"3ec126568c18a7916912fb9fbecf812337ec6b84","size":2836,"noattachment":false,"key":"/tiny-async-pool/-/tiny-async-pool-2.1.0.tgz","tarball":"http://registry.cnpm.dingdandao.com/tiny-async-pool/download/tiny-async-pool-2.1.0.tgz"},"_npmUser":{"name":"rxaviers","email":"rxaviers@gmail.com"},"directories":{},"maintainers":[{"name":"rxaviers","email":""}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/tiny-async-pool_2.1.0_1652180853323_0.23631932784911402"},"_hasShrinkwrap":false,"_cnpmcore_publish_time":"2022-05-10T13:17:04.065Z","publish_time":1652180853475,"_cnpm_publish_time":1652180853475},"2.0.1":{"name":"tiny-async-pool","version":"2.0.1","description":"Run multiple promise-returning & async functions with limited concurrency using native ES9","main":"lib/es9.js","scripts":{"prettier":"prettier --write '{lib,test}/**/*.js'","test":"eslint lib && NODE_ENV=development mocha"},"repository":{"type":"git","url":"git+ssh://git@github.com/rxaviers/async-pool.git"},"keywords":["race","concurrency","promise","async","async iterator","async iteration","async generator","es9"],"author":{"name":"Rafael Xavier de Souza"},"license":"MIT","devDependencies":{"babel-eslint":"^10.1.0","chai":"^4.1.2","chai-as-promised":"^7.1.1","eslint":"^4.17.0","eslint-config-prettier":"^2.9.0","eslint-plugin-prettier":"^2.6.0","mocha":"^5.0.0","prettier":"^1.10.2"},"dependencies":{},"gitHead":"f37c38764f7e469acac142b035298c5ecb46bd55","bugs":{"url":"https://github.com/rxaviers/async-pool/issues"},"homepage":"https://github.com/rxaviers/async-pool#readme","_id":"tiny-async-pool@2.0.1","_nodeVersion":"14.17.0","_npmVersion":"6.14.13","dist":{"shasum":"b91a5e9fa539f2d89b2201cd843a7341fe2710a7","size":2571,"noattachment":false,"key":"/tiny-async-pool/-/tiny-async-pool-2.0.1.tgz","tarball":"http://registry.cnpm.dingdandao.com/tiny-async-pool/download/tiny-async-pool-2.0.1.tgz"},"_npmUser":{"name":"rxaviers","email":"rxaviers@gmail.com"},"directories":{},"maintainers":[{"name":"rxaviers","email":""}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/tiny-async-pool_2.0.1_1647779741076_0.8065340392935421"},"_hasShrinkwrap":false,"_cnpmcore_publish_time":"2022-03-20T12:35:44.123Z","publish_time":1647779741213,"_cnpm_publish_time":1647779741213},"2.0.0":{"name":"tiny-async-pool","version":"2.0.0","description":"Run multiple promise-returning & async functions with limited concurrency using native ES9","main":"lib/es9.js","scripts":{"prettier":"prettier --write '{lib,test}/**/*.js'","test":"eslint src && NODE_ENV=development mocha"},"repository":{"type":"git","url":"git+ssh://git@github.com/rxaviers/async-pool.git"},"keywords":["race","concurrency","promise","async","async iterator","async iteration","async generator","es9"],"author":{"name":"Rafael Xavier de Souza"},"license":"MIT","devDependencies":{"chai":"^4.1.2","chai-as-promised":"^7.1.1","eslint":"^4.17.0","eslint-config-prettier":"^2.9.0","eslint-plugin-prettier":"^2.6.0","mocha":"^5.0.0","prettier":"^1.10.2"},"dependencies":{},"gitHead":"433088379b10135949b1df03ca3a85b4ef53d835","bugs":{"url":"https://github.com/rxaviers/async-pool/issues"},"homepage":"https://github.com/rxaviers/async-pool#readme","_id":"tiny-async-pool@2.0.0","_nodeVersion":"14.17.0","_npmVersion":"6.14.13","dist":{"shasum":"03bf2d10731a14ad4f86cb1ec894b33bfb3cf5b4","size":2595,"noattachment":false,"key":"/tiny-async-pool/-/tiny-async-pool-2.0.0.tgz","tarball":"http://registry.cnpm.dingdandao.com/tiny-async-pool/download/tiny-async-pool-2.0.0.tgz"},"_npmUser":{"name":"rxaviers","email":"rxaviers@gmail.com"},"directories":{},"maintainers":[{"name":"rxaviers","email":""}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/tiny-async-pool_2.0.0_1647608948787_0.6432510633355017"},"_hasShrinkwrap":false,"_cnpmcore_publish_time":"2022-03-18T13:09:28.181Z","publish_time":1647608948997,"_cnpm_publish_time":1647608948997},"1.3.0":{"name":"tiny-async-pool","version":"1.3.0","description":"Run multiple promise-returning & async functions with limited concurrency using native ES6/ES7","main":"dist/node.js","scripts":{"prettier":"prettier --write '{lib,test}/**/*.js'","test":"eslint src && NODE_ENV=development mocha"},"repository":{"type":"git","url":"git+ssh://git@github.com/rxaviers/async-pool.git"},"keywords":["race","concurrency","promise","async","es6","es7"],"author":{"name":"Rafael Xavier de Souza"},"license":"MIT","devDependencies":{"chai":"^4.1.2","chai-as-promised":"^7.1.1","eslint":"^4.17.0","eslint-config-prettier":"^2.9.0","eslint-plugin-prettier":"^2.6.0","mocha":"^5.0.0","prettier":"^1.10.2"},"dependencies":{"semver":"^5.5.0"},"gitHead":"0fde0fefa538210432d14ebdb3b750fe10c2094c","bugs":{"url":"https://github.com/rxaviers/async-pool/issues"},"homepage":"https://github.com/rxaviers/async-pool#readme","_id":"tiny-async-pool@1.3.0","_nodeVersion":"14.17.0","_npmVersion":"6.14.13","dist":{"shasum":"c013e1b369095e7005db5595f95e646cca6ef8a5","size":2677,"noattachment":false,"key":"/tiny-async-pool/-/tiny-async-pool-1.3.0.tgz","tarball":"http://registry.cnpm.dingdandao.com/tiny-async-pool/download/tiny-async-pool-1.3.0.tgz"},"_npmUser":{"name":"rxaviers","email":"rxaviers@gmail.com"},"directories":{},"maintainers":[{"name":"rxaviers","email":""}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/tiny-async-pool_1.3.0_1647608052905_0.3065291976500297"},"_hasShrinkwrap":false,"_cnpmcore_publish_time":"2022-03-18T12:54:24.844Z","publish_time":1647608053079,"_cnpm_publish_time":1647608053079},"1.2.0":{"name":"tiny-async-pool","version":"1.2.0","description":"Run multiple promise-returning & async functions with limited concurrency using native ES6/ES7","main":"dist/node.js","scripts":{"prettier":"prettier --write '{lib,test}/**/*.js'","test":"eslint src && NODE_ENV=development mocha"},"repository":{"type":"git","url":"git+ssh://git@github.com/rxaviers/async-pool.git"},"keywords":["race","concurrency","promise","async","es6","es7"],"author":{"name":"Rafael Xavier de Souza"},"license":"MIT","devDependencies":{"chai":"^4.1.2","chai-as-promised":"^7.1.1","eslint":"^4.17.0","eslint-config-prettier":"^2.9.0","eslint-plugin-prettier":"^2.6.0","mocha":"^5.0.0","prettier":"^1.10.2"},"dependencies":{"yaassertion":"^1.0.0","semver":"^5.5.0"},"gitHead":"f81e56d5f08c9ba83e0ca95b43034f310e558444","bugs":{"url":"https://github.com/rxaviers/async-pool/issues"},"homepage":"https://github.com/rxaviers/async-pool#readme","_id":"tiny-async-pool@1.2.0","_nodeVersion":"12.14.0","_npmVersion":"6.13.4","dist":{"shasum":"22132957e18f8b6020a94b390d07718fd519cc71","size":2681,"noattachment":false,"key":"/tiny-async-pool/-/tiny-async-pool-1.2.0.tgz","tarball":"http://registry.cnpm.dingdandao.com/tiny-async-pool/download/tiny-async-pool-1.2.0.tgz"},"maintainers":[{"name":"rxaviers","email":""}],"_npmUser":{"name":"rxaviers","email":"rxaviers@gmail.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/tiny-async-pool_1.2.0_1603844300312_0.1526134924857605"},"_hasShrinkwrap":false,"publish_time":1603844300464,"_cnpm_publish_time":1603844300464,"_cnpmcore_publish_time":"2021-12-16T13:38:21.723Z"},"1.1.0":{"name":"tiny-async-pool","version":"1.1.0","description":"Run multiple promise-returning & async functions with limited concurrency using native ES6/ES7","main":"dist/node.js","scripts":{"prettier":"prettier --write '{src,test}/**/*.{js}'","test":"eslint src && NODE_ENV=development mocha"},"repository":{"type":"git","url":"git+ssh://git@github.com/rxaviers/async-pool.git"},"keywords":["race","concurrency","promise","async","es6","es7"],"author":{"name":"Rafael Xavier de Souza"},"license":"MIT","devDependencies":{"chai":"^4.1.2","chai-as-promised":"^7.1.1","eslint":"^4.17.0","eslint-config-prettier":"^2.9.0","eslint-plugin-prettier":"^2.6.0","mocha":"^5.0.0","prettier":"^1.10.2"},"dependencies":{"yaassertion":"^1.0.0","semver":"^5.5.0"},"gitHead":"55e00c825043b8ba2e580bc3042c7332c9eb8b55","bugs":{"url":"https://github.com/rxaviers/async-pool/issues"},"homepage":"https://github.com/rxaviers/async-pool#readme","_id":"tiny-async-pool@1.1.0","_nodeVersion":"10.17.0","_npmVersion":"6.11.3","dist":{"shasum":"cd3fdafaae84f2aa2539a07b428b40f801219c5b","size":2707,"noattachment":false,"key":"/tiny-async-pool/-/tiny-async-pool-1.1.0.tgz","tarball":"http://registry.cnpm.dingdandao.com/tiny-async-pool/download/tiny-async-pool-1.1.0.tgz"},"maintainers":[{"name":"rxaviers","email":""}],"_npmUser":{"name":"rxaviers","email":"rxaviers@gmail.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/tiny-async-pool_1.1.0_1574862017674_0.6451258822875718"},"_hasShrinkwrap":false,"publish_time":1574862017775,"_cnpm_publish_time":1574862017775,"_cnpmcore_publish_time":"2021-12-16T13:38:21.940Z"},"1.0.4":{"name":"tiny-async-pool","version":"1.0.4","description":"Run multiple promise-returning & async functions with limited concurrency using native ES6/ES7","main":"dist/node.js","scripts":{"prettier":"prettier --write '{src,test}/**/*.{js}'","test":"eslint src && NODE_ENV=development mocha"},"repository":{"type":"git","url":"git+ssh://git@github.com/rxaviers/async-pool.git"},"keywords":["race","concurrency","promise","async","es6","es7"],"author":{"name":"Rafael Xavier de Souza"},"license":"MIT","devDependencies":{"chai":"^4.1.2","chai-as-promised":"^7.1.1","eslint":"^4.17.0","eslint-config-prettier":"^2.9.0","eslint-plugin-prettier":"^2.6.0","mocha":"^5.0.0","prettier":"^1.10.2"},"dependencies":{"yaassertion":"^1.0.0","semver":"^5.5.0"},"gitHead":"3da6d9fdb927f418bb2de37e176fefe0e880de8a","bugs":{"url":"https://github.com/rxaviers/async-pool/issues"},"homepage":"https://github.com/rxaviers/async-pool#readme","_id":"tiny-async-pool@1.0.4","_npmVersion":"5.10.0","_nodeVersion":"6.11.2","_npmUser":{"name":"rxaviers","email":"rxaviers@gmail.com"},"dist":{"shasum":"bbac28a39a754576d8d0615d4e2ad35c87da6169","size":2680,"noattachment":false,"key":"/tiny-async-pool/-/tiny-async-pool-1.0.4.tgz","tarball":"http://registry.cnpm.dingdandao.com/tiny-async-pool/download/tiny-async-pool-1.0.4.tgz"},"maintainers":[{"name":"rxaviers","email":""}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/tiny-async-pool_1.0.4_1540582454348_0.5551662491114124"},"_hasShrinkwrap":false,"publish_time":1540582454553,"_cnpm_publish_time":1540582454553,"_cnpmcore_publish_time":"2021-12-16T13:38:22.152Z"},"1.0.3":{"name":"tiny-async-pool","version":"1.0.3","description":"Run multiple promise-returning & async functions with limited concurrency using native ES6/ES7","main":"dist/node.js","scripts":{"prettier":"prettier --write '{src,test}/**/*.{js}'","test":"eslint src && NODE_ENV=development mocha"},"repository":{"type":"git","url":"git+ssh://git@github.com/rxaviers/async-pool.git"},"keywords":["race","concurrency","promise","async","es6","es7"],"author":{"name":"Rafael Xavier de Souza"},"license":"MIT","devDependencies":{"chai":"^4.1.2","chai-as-promised":"^7.1.1","eslint":"^4.17.0","eslint-config-prettier":"^2.9.0","eslint-plugin-prettier":"^2.6.0","mocha":"^5.0.0","prettier":"^1.10.2"},"dependencies":{"yaassertion":"^1.0.0","semver":"^5.5.0"},"gitHead":"e1bbd917247f359d5d3000aebd47b5b1d1912bac","bugs":{"url":"https://github.com/rxaviers/async-pool/issues"},"homepage":"https://github.com/rxaviers/async-pool#readme","_id":"tiny-async-pool@1.0.3","_npmVersion":"5.5.1","_nodeVersion":"6.14.1","_npmUser":{"name":"rxaviers","email":"rxaviers@gmail.com"},"dist":{"shasum":"19c704c51b420b644615c65b28aa860e39a3ddcc","size":2714,"noattachment":false,"key":"/tiny-async-pool/-/tiny-async-pool-1.0.3.tgz","tarball":"http://registry.cnpm.dingdandao.com/tiny-async-pool/download/tiny-async-pool-1.0.3.tgz"},"maintainers":[{"name":"rxaviers","email":""}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/tiny-async-pool_1.0.3_1540405136929_0.5071360898089685"},"_hasShrinkwrap":false,"publish_time":1540405137135,"_cnpm_publish_time":1540405137135,"_cnpmcore_publish_time":"2021-12-16T13:38:22.396Z"},"1.0.2":{"name":"tiny-async-pool","version":"1.0.2","description":"Run multiple promise-returning & async functions with limited concurrency using native ES6/ES7","main":"dist/node.js","scripts":{"prettier":"prettier --write '{src,test}/**/*.{js}'","test":"eslint src && NODE_ENV=development mocha"},"repository":{"type":"git","url":"git+ssh://git@github.com/rxaviers/async-pool.git"},"keywords":["race","concurrency","promise","async","es6","es7"],"author":{"name":"Rafael Xavier de Souza"},"license":"MIT","devDependencies":{"chai":"^4.1.2","chai-as-promised":"^7.1.1","eslint":"^4.17.0","eslint-config-prettier":"^2.9.0","eslint-plugin-prettier":"^2.6.0","mocha":"^5.0.0","prettier":"^1.10.2"},"dependencies":{"yaassertion":"^1.0.0","semver":"^5.5.0"},"gitHead":"54c5ef024160ba7759e9b8ca40c15ff9e77de8a4","bugs":{"url":"https://github.com/rxaviers/async-pool/issues"},"homepage":"https://github.com/rxaviers/async-pool#readme","_id":"tiny-async-pool@1.0.2","_npmVersion":"5.5.1","_nodeVersion":"6.14.1","_npmUser":{"name":"rxaviers","email":"rxaviers@gmail.com"},"dist":{"shasum":"155dca40a2091a55dccd7e7cf5403513e4ac5c16","size":2703,"noattachment":false,"key":"/tiny-async-pool/-/tiny-async-pool-1.0.2.tgz","tarball":"http://registry.cnpm.dingdandao.com/tiny-async-pool/download/tiny-async-pool-1.0.2.tgz"},"maintainers":[{"name":"rxaviers","email":""}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/tiny-async-pool_1.0.2_1540302527466_0.9997371161105744"},"_hasShrinkwrap":false,"publish_time":1540302527639,"_cnpm_publish_time":1540302527639,"_cnpmcore_publish_time":"2021-12-16T13:38:22.626Z"},"1.0.1":{"name":"tiny-async-pool","version":"1.0.1","description":"Run multiple promise-returning & async functions with limited concurrency using native ES6/ES7","main":"dist/node.js","scripts":{"prettier":"prettier --write '{src,test}/**/*.{js}'","test":"eslint src && NODE_ENV=development mocha"},"repository":{"type":"git","url":"git+ssh://git@github.com/rxaviers/async-pool.git"},"keywords":["race","concurrency","promise","async","es6","es7"],"author":{"name":"Rafael Xavier de Souza"},"license":"MIT","devDependencies":{"chai":"^4.1.2","chai-as-promised":"^7.1.1","eslint":"^4.17.0","eslint-config-prettier":"^2.9.0","eslint-plugin-prettier":"^2.6.0","mocha":"^5.0.0","prettier":"^1.10.2"},"dependencies":{"assertion":"github:rxaviers/assertion","semver":"^5.5.0"},"gitHead":"a5861c8aa34c8aeabbf6d5d37cae26fb3922970e","bugs":{"url":"https://github.com/rxaviers/async-pool/issues"},"homepage":"https://github.com/rxaviers/async-pool#readme","_id":"tiny-async-pool@1.0.1","_npmVersion":"5.5.1","_nodeVersion":"6.14.1","_npmUser":{"name":"rxaviers","email":"rxaviers@gmail.com"},"dist":{"shasum":"7480c89088285c8384a273a4da22bafbd280960c","size":3384,"noattachment":false,"key":"/tiny-async-pool/-/tiny-async-pool-1.0.1.tgz","tarball":"http://registry.cnpm.dingdandao.com/tiny-async-pool/download/tiny-async-pool-1.0.1.tgz"},"maintainers":[{"name":"rxaviers","email":""}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/tiny-async-pool_1.0.1_1530651056087_0.4457101042942764"},"_hasShrinkwrap":false,"publish_time":1530651056150,"_cnpm_publish_time":1530651056150,"_cnpmcore_publish_time":"2021-12-16T13:38:22.849Z"},"1.0.0":{"name":"tiny-async-pool","version":"1.0.0","description":"Run multiple promise-returning & async functions with limited concurrency using native ES6/ES7","main":"dist/node.js","scripts":{"prettier":"prettier --write '{src,test}/**/*.{js}'","test":"eslint src && NODE_ENV=development mocha"},"repository":{"type":"git","url":"git+ssh://git@github.com/rxaviers/assertion.git"},"keywords":["race","concurrency","promise","async","es6","es7"],"author":{"name":"Rafael Xavier de Souza"},"license":"MIT","devDependencies":{"chai":"^4.1.2","chai-as-promised":"^7.1.1","eslint":"^4.17.0","eslint-config-prettier":"^2.9.0","eslint-plugin-prettier":"^2.6.0","mocha":"^5.0.0","prettier":"^1.10.2"},"dependencies":{"assertion":"github:rxaviers/assertion","semver":"^5.5.0"},"gitHead":"18ae8f00e458bf251099381f78d73242d971088a","bugs":{"url":"https://github.com/rxaviers/assertion/issues"},"homepage":"https://github.com/rxaviers/assertion#readme","_id":"tiny-async-pool@1.0.0","_shasum":"edbdc00dbd2f13c7ef1b6c77977a94e7509d52f8","_from":".","_npmVersion":"4.4.0","_nodeVersion":"4.8.0","_npmUser":{"name":"rxaviers","email":"rxaviers@gmail.com"},"dist":{"shasum":"edbdc00dbd2f13c7ef1b6c77977a94e7509d52f8","size":15094,"noattachment":false,"key":"/tiny-async-pool/-/tiny-async-pool-1.0.0.tgz","tarball":"http://registry.cnpm.dingdandao.com/tiny-async-pool/download/tiny-async-pool-1.0.0.tgz"},"maintainers":[{"name":"rxaviers","email":""}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/tiny-async-pool_1.0.0_1529914512150_0.3879701656061725"},"_hasShrinkwrap":false,"publish_time":1529914512281,"_cnpm_publish_time":1529914512281,"_cnpmcore_publish_time":"2021-12-16T13:38:23.116Z"}},"readme":"# asyncPool\n\n## Why?\n\nThe goal of this library is to use native async iterator (ES9), native async functions and native Promise to implement the concurrency behavior (look our source code).\n\nIf you need ES6 as baseline, please use our version [1.x](https://github.com/rxaviers/async-pool/tree/1.x).\n\n## What?\n\n`asyncPool` runs multiple promise-returning & async functions in a limited concurrency pool. It rejects immediately as soon as one of the promises rejects. It calls the iterator function as soon as possible (under concurrency limit). It returns an async iterator that yields as soon as a promise completes (under concurrency limit). For example:\n\n```js\nconst timeout = ms => new Promise(resolve => setTimeout(() => resolve(ms), ms));\n\nfor await (const ms of asyncPool(2, [1000, 5000, 3000, 2000], timeout)) {\n  console.log(ms);\n}\n// Call iterator timeout(1000)\n// Call iterator timeout(5000)\n// Concurrency limit of 2 reached, wait for the quicker one to complete...\n// 1000 finishes\n// for await...of outputs \"1000\"\n// Call iterator timeout(3000)\n// Concurrency limit of 2 reached, wait for the quicker one to complete...\n// 3000 finishes\n// for await...of outputs \"3000\"\n// Call iterator timeout(2000)\n// Itaration is complete, wait until running ones complete...\n// 5000 finishes\n// for await...of outputs \"5000\"\n// 2000 finishes\n// for await...of outputs \"2000\"\n```\n\n## Usage\n\n```\n$ npm install tiny-async-pool\n```\n\n```js\nimport asyncPool from \"tiny-async-pool\";\n```\n\n### ES9 for await...of\n\n```js\nfor await (const value of asyncPool(concurrency, iterable, iteratorFn)) {\n  ...\n}\n```\n\n## Migrating from 1.x\n\nThe main difference: [1.x API](https://github.com/rxaviers/async-pool/tree/1.x) waits until all of the promises completes, then all results are returned (example below). The new API (thanks to [async iteration](https://github.com/tc39/proposal-async-iteration)) let each result be returned as soon as it completes (example above).\n\nYou may prefer to keep the 1.x style syntax, instead of the `for await` iteration method in 2.x. Define a function like below to wrap `asyncPool`, and this function will allow you to upgrade to 2.x without having to heavily modify your existing code.\n\n```js\nasync function asyncPoolAll(...args) {\n  const results = [];\n  for await (const result of asyncPool(...args)) {\n    results.push(result);\n  }\n  return results;\n}\n\n// ES7 API style available on our previous 1.x version\nconst results = await asyncPoolAll(concurrency, iterable, iteratorFn);\n\n// ES6 API style available on our previous 1.x version\nreturn asyncPoolAll(2, [1000, 5000, 3000, 2000], timeout).then(results => {...});\n```\n\n## API\n\n### `asyncPool(concurrency, iterable, iteratorFn)`\n\nRuns multiple promise-returning & async functions in a limited concurrency pool. It rejects immediately as soon as one of the promises rejects. It calls the iterator function as soon as possible (under concurrency limit). It returns an async iterator that yields as soon as a promise completes (under concurrency limit).\n\n#### concurrency\n\nThe concurrency limit number (>= 1).\n\n#### iterable\n\nAn input [iterable object](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols#the_iterable_protocol), such as [`String`](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/String), [`Array`](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Array), [`TypedArray`](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/TypedArray), [`Map`](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Map), and [`Set`](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Set).\n\n#### iteratorFn\n\nIterator function that takes two arguments: the value of each iteration and the iterable object itself. The iterator function should either return a promise or be an async function.\n\n## License\n\nMIT © [Rafael Xavier de Souza](http://rafael.xavier.blog.br)\n","_attachments":{},"homepage":"https://github.com/rxaviers/async-pool#readme","bugs":{"url":"https://github.com/rxaviers/async-pool/issues"},"license":"MIT"}