Q

import { queue } from '../mod.ts'; // TODO: update with public link

let result = 0;
const task = (a: number) => (result += a);
const q = queue(task, 2); // 2 is concurrency

q.drain(()=>{console.log(`Result: ${result}`)}); // will log `Result: 6`

q.push(1);
q.push([2, 3]);

import { queue } from '../mod.ts';

(async () => {
  let result = 0;
  const task = (a: number) => (result += a);
  const q = queue(task, 2); // 2 is concurrency

  q.push(1);
  q.push([2, 3]);

  await q.drain();
  console.log(`Result: ${result}`);
})();