summaryrefslogtreecommitdiffstats
path: root/node_modules/fastq/test/example.ts
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/fastq/test/example.ts')
-rw-r--r--node_modules/fastq/test/example.ts63
1 files changed, 0 insertions, 63 deletions
diff --git a/node_modules/fastq/test/example.ts b/node_modules/fastq/test/example.ts
deleted file mode 100644
index 9e29e47..0000000
--- a/node_modules/fastq/test/example.ts
+++ /dev/null
@@ -1,63 +0,0 @@
-import * as fastq from '../'
-
-// Basic example
-
-const queue = fastq(worker, 1)
-
-queue.push('world', (err, result) => {
- if (err) throw err
- console.log('the result is', result)
-})
-
-queue.concurrency
-
-queue.drain()
-
-queue.empty = () => undefined
-
-console.log('the queue tasks are', queue.getQueue())
-
-queue.idle()
-
-queue.kill()
-
-queue.killAndDrain()
-
-queue.length
-
-queue.pause()
-
-queue.resume()
-
-queue.saturated = () => undefined
-
-queue.unshift('world', (err, result) => {
- if (err) throw err
- console.log('the result is', result)
-})
-
-function worker(task: any, cb: fastq.done) {
- cb(null, 'hello ' + task)
-}
-
-// Generics example
-
-interface GenericsContext {
- base: number;
-}
-
-const genericsQueue = fastq<GenericsContext, number, string>({ base: 6 }, genericsWorker, 1)
-
-genericsQueue.push(7, (err, done) => {
- if (err) throw err
- console.log('the result is', done)
-})
-
-genericsQueue.unshift(7, (err, done) => {
- if (err) throw err
- console.log('the result is', done)
-})
-
-function genericsWorker(this: GenericsContext, task: number, cb: fastq.done<string>) {
- cb(null, 'the meaning of life is ' + (this.base * task))
-}