Promise Pool Showcase

product_import_promise_all.js

const { products } = require("./products");

async function execute() {
  const promises = []

  // Running each import product process parallel
  for await (const data of products) {
    const importPromise = importProduct(data);
    promises.push(importPromise)
  }

  // Waited to finish all products at once and returns inserted product data from database
  const importedProducts = await Promise.all(promises)
}

async function importProduct(data) {
  return createProduct(data);
}

execute();

Complete Git repo: https://github.com/priyankatgit/promise-pool-demo