strapi/packages/core/utils/lib/async.js

'use strict';

const pMap = require('p-map');
const { curry } = require('lodash/fp');

function pipeAsync(...methods) {
  return async (data) => {
    let res = data;

    for (const method of methods) {
      res = await method(res);
    }

    return res;
  };
}

/**
 * @type { import('./async').MapAsync }
 */
const mapAsync = curry(pMap);

/**
 * @type { import('./async').ForEachAsync }
 */
const forEachAsync = curry(async (array, func, options) => {
  await mapAsync(array, func, options);
});

module.exports = {
  mapAsync,
  forEachAsync,
  pipeAsync,
};