Queue-function-api NPM

Queue function , Queue function in api

Node API adapter in ECMAScript 2015 (ES6)

Installation

Install the queue-function-api package in your node server app's local node_modules folder.

npm i queue-function-api

How to start

const QueueFunction = require('queue-function-api');

/**
 *
 * @param {number} _maxConcurrency
 * @param {array - function} results
 */
const queue = new QueueFunction(1, []);
queue.on('running', function (fn, results = []) {
    console.log(fn)
    console.log("results", results)
});
queue.on('exist', function (fn , results = []) {
     console.log(fn)
     console.log("results", results)

},);
queue.on('error', function (error, results = []) {
     console.log(error)
     console.log("results", results)
});

const delay = (ms) => new Promise((res) => setTimeout(res, ms));

queue.push(async function one() {
  await delay(2000);
  console.log(1);
});

queue.push(async function two() {
  await delay(2000);
  console.log(2);
});

queue.push(async function three() {
  await delay(2500);
  console.log(3);
});

queue.push(async function four() {
  await delay(2000);
  console.log(5);
});

queue.push(async function one() {
  await delay(2000);
  console.log(1);
});

queue.push(async function two() {
  await delay(2000);
  console.log(2);
});

queue.push(async function three() {
  await delay(2500);
  console.log(3);
});

queue.push(async function four() {
  await delay(2000);
  console.log(5);
});

const QueueFunction = require('queue-function-api');
/**
*
* @param {number} _maxConcurrency
* @param {array - function} results
*/
function one(){
    console.log('1');
}
function two(){
    console.log('2');
}
const queue = new QueueFunction(1, [two, one]);
// queue will automatic execute when length results > 0

How to using in api

const QueueFunction = require('queue-function-api');
/**
*
* @param {number} _maxConcurrency
* @param {array - function} results
*/
const app = express();
app.request.q = new QueueFunction(1);

// function in controller
function getUser(req, res) => {
    const functionQueue = async () => {
        // handle something
        // can be using return response at here
        const data =  await userService.get(req.params.id);
        return await res.send(data)
    }
    req.q.push(functionQueue)
}

const QueueFunction = require('queue-function-api');
/**
*
* @param {number} _maxConcurrency
* @param {array - function} results
*/
const app = express();
global.queue = new Queue(1);

// function in controller
function getUser(req, res) => {
    const functionQueue = async () => {
        // handle something
        // can be using return response at here
        const data =  await userService.get(req.params.id);
        return await res.send(data)
    }
    global.queue.push(functionQueue)
}