Process (async)iterable values as functions with concurrency control
npm install it-parallel-batch
> Process (async)iterable values as functions with concurrency control
Takes an async iterator that emits promise-returning functions, invokes them in parallel and emits the results in the same order as the input.
The final batch may be smaller than the batch size.
``javascript
import parallelBatch from 'it-parallel-batch'
import all from 'it-all'
import delay from 'delay'
// This can also be an iterator, async iterator, generator, etc
const input = [
async () => {
await delay(500)
return 1
},
async () => {
await delay(200)
return 2
},
async () => {
await delay(100)
return 3
}
]
const batchSize = 2
const result = await all(parallelBatch(input, batchSize))
console.info(result) // [1, 2, 3]
`
`console`
$ npm i it-parallel-batch
-
Licensed under either of
- Apache 2.0, (LICENSE-APACHE /
- MIT (LICENSE-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.