Pact

Process promise-based tasks in series and parallel, controlling concurrency and throttling.

Installation

npm install lupomontero/pact

Usage / API

`Promise pact(tasks, concurrency, interval, failFast)`

Arguments

tasks (Array): An array of tasks, where each task is a function that expects no arguments and will return a Promise.
concurrency (Number): Default: 1. Maximum number of tasks to run concurrently (in parallel).
interval (Number): Default: 0. Interval between each batch of concurrent tasks.
failFast (Boolean): Default: true. Whether to bail out when one of the promises fails. If set to false errors will be included in the results passed to then() instead of being passed independently via the catch() method.

Return value

A Promise that will resolve to an array with the results for each task. Results will be in the same order as in the input tasks array.

Examples

Series

Process each task after the other, sequentially. Each task will wait for the previous one to complete. Concurrency set to 1 (one task at a time).

const pact = require('pact');
const tasks = users.map(user => () => auth.deleteUser(user.localId);

pact(tasks)
  .then(console.log)
  .catch(console.error);

Batches

Process tasks in batches based on a given concurrency. In this example tasks will be processed in batches of 5 tasks each. Each batch waits for the previous one to complete and then performs its tasks in parallel.

pact(tasks, 5)
  .then(console.log)
  .catch(console.error);

Throttled

Same as example above but adding a 1000ms delay between batches.

pact(tasks, 5, 1000)
  .then(console.log)
  .catch(console.error);

failFast=false (don't bail out on errors)

Same as above, but in this case if a promise fails, processing will continue instead of stopping the whole thing. When failFast is set to false, errors will appear as the value/result for the relevant element in the results array (failed tasks/promises won't end up in the catch() method).

pact(tasks, 5, 1000, false)
  .then(console.log)
  .catch(console.error);

giancorzo/pact