Process an array of items concurrently

$ yarn add process-concurrent

processConcurrent(items, itemProcessor, options)

Valid options are:

• concurrency - Number of items to process concurrently (default 5)
• maxTries - Number of retries if itemProcessor throws an error (default 3)

A simple example

const concurrent = require('process-concurrent')

const items = ['a', 'b', 'c', 'd', 'e', 'f', 'g']

const processItem = (item) => console.log(`Process ${item}`)

concurrent(items, processItem)

Async with options

const concurrent = require('process-concurrent')

const items = ['a', 'b', 'c', 'd', 'e', 'f', 'g']

const processItem = (item) => new Promise(resolve => {
    setTimeout(() => {
        console.log(`Process ${item}`)
        resolve()
    }, Math.random() * 100)
})

concurrent(items, processItem, { concurrency: 4, maxTries: 3 })