summaryrefslogtreecommitdiff
path: root/node_modules/fastq/test/example.ts
diff options
context:
space:
mode:
authorlittleblack111 <littleblack11111@gmail.com>2026-05-18 23:10:59 +0800
committerlittleblack111 <littleblack11111@gmail.com>2026-05-18 23:41:44 +0800
commitfc87c009806dcc98867f6b58efe29b042aa01dee (patch)
tree8f59b3f4a5b66e9dfef2d40c8d318e258a521228 /node_modules/fastq/test/example.ts
parent3336b2356ee6152d9c6ae59bd9b87ccbc0958407 (diff)
node: updatemain
Diffstat (limited to 'node_modules/fastq/test/example.ts')
-rw-r--r--node_modules/fastq/test/example.ts83
1 files changed, 0 insertions, 83 deletions
diff --git a/node_modules/fastq/test/example.ts b/node_modules/fastq/test/example.ts
deleted file mode 100644
index a47d4419..00000000
--- a/node_modules/fastq/test/example.ts
+++ /dev/null
@@ -1,83 +0,0 @@
-import * as fastq from '../'
-import { promise as queueAsPromised } from '../'
-
-// Basic example
-
-const queue = fastq(worker, 1)
-
-queue.push('world', (err, result) => {
- if (err) throw err
- console.log('the result is', result)
-})
-
-queue.push('push without cb')
-
-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.running()
-
-queue.saturated = () => undefined
-
-queue.unshift('world', (err, result) => {
- if (err) throw err
- console.log('the result is', result)
-})
-
-queue.unshift('unshift without cb')
-
-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))
-}
-
-const queue2 = queueAsPromised(asyncWorker, 1)
-
-async function asyncWorker(task: any) {
- return 'hello ' + task
-}
-
-async function run () {
- await queue.push(42)
- await queue.unshift(42)
-}
-
-run()