fastq

Install

Usage (callback API)

Usage (promise API)

Setting "this"

Using with TypeScript (callback API)

Using with TypeScript (promise API)

API

fastqueue([that], worker, concurrency)

queue.push(task, done)

queue.unshift(task, done)

queue.pause()

queue.resume()

queue.idle()

queue.length()

queue.getQueue()

queue.kill()

queue.killAndDrain()

queue.error(handler)

queue.concurrency

queue.paused

queue.drain

queue.empty

queue.saturated

fastqueue.promise([that], worker(arg), concurrency)

queue.push(task) => Promise

queue.unshift(task) => Promise

queue.drained() => Promise

License