@egoist/promise-queue

Install

For Node.js / Yarn:

yarn add @egoist/promise-queue

For Node.js / NPM:

npm i @egoist/promise-queue

For Deno:

import { PromiseQueue } from 'https://unpkg.com/@egoist/promise-queue/mod.ts'

Usage

Example using Node.js CommonJS require:

const { PromiseQueue } = require('@egoist/promise-queue')

const processor = async (jobId, resolution, format) => {
  // run job
}

const queue = new PromiseQueue(processor)

// Add a job
// First argument is an unique job id
queue.add('process-video-id-xxxx', '720p', 'mp4')

// Run added jobs
// Resolves a Set of processed job ids
await queue.run()

TypeDoc

https://doc.deno.land/https/raw.githubusercontent.com/egoist/promise-queue/master/src/index.ts

Contributing

1. Fork it!
2. Create your feature branch: git checkout -b my-new-feature
3. Commit your changes: git commit -am 'Add some feature'
4. Push to the branch: git push origin my-new-feature
5. Submit a pull request :D

Author

@egoist/promise-queue © EGOIST, Released under the MIT License. Authored and maintained by EGOIST with help from contributors (list).

github.com/egoist · GitHub @EGOIST · Twitter @_egoistlily