JS Async queue

This is a helper class that resolves a queue with a concurrency limit ( I.e. limit the amount of concurrent processes ) and provides an array of responses once it has completed the queue.

Installation

npm install js-async-queue

Usage

The class requires 3 parameters: -Tasks array -Concurrency limit -Function to be computed ( Promise )

import queue from 'js-async-queue'
//const queue = require('js-async-queue')

//This function will be ran with each element in the queue

let mockFunction = (task) =>{

  return new Promise(async (resolve, reject) => {
    try{
      let response = await fetch('http://5ba71c7868c16e0014c4eea2.mockapi.io/test/' + task);
      response = await response.json()
      resolve(response)
    } catch(e) {
      console.log(e)
      reject(e)
    }
  });

}

//Create a new instanaceof the queue
//First Param is an array
//Second param is the max amount of concurrent processes
//Third Param is the function that will run with each task in the queue

let enqueue = new queue(['Ingredients', 'tasks', 'things', 'persons', 'art'], 2, mockFunction);

enqueue.start().then((res)=> console.log(res));

Why the fuck did I even build this?

Well, I wanted to practice JS classes.

Where to use it?

Mostly this class will be used by puppeteer users to make sure their computers don't run out of ram while crawling a site and they can keep an efficient queue with concurrent tasks.