summaryrefslogtreecommitdiffstats
path: root/node_modules/fastq
diff options
context:
space:
mode:
authorGravatar Piotr Russ <mail@pruss.it> 2020-11-18 23:26:45 +0100
committerGravatar Piotr Russ <mail@pruss.it> 2020-11-18 23:26:45 +0100
commit81ddf9b700bc48a1f8e472209f080f9c1d9a9b09 (patch)
tree8b959d50c5a614cbf9fcb346ed556140374d4b6d /node_modules/fastq
parent1870f3fdf43707a15fda0f609a021f516f45eb63 (diff)
downloadwebsite_creator-81ddf9b700bc48a1f8e472209f080f9c1d9a9b09.tar.gz
website_creator-81ddf9b700bc48a1f8e472209f080f9c1d9a9b09.tar.bz2
website_creator-81ddf9b700bc48a1f8e472209f080f9c1d9a9b09.zip
rm node_modules
Diffstat (limited to 'node_modules/fastq')
-rw-r--r--node_modules/fastq/.github/workflows/ci.yml50
-rw-r--r--node_modules/fastq/LICENSE13
-rw-r--r--node_modules/fastq/README.md208
-rw-r--r--node_modules/fastq/bench.js58
-rw-r--r--node_modules/fastq/example.js12
-rw-r--r--node_modules/fastq/index.d.ts27
-rw-r--r--node_modules/fastq/package.json75
-rw-r--r--node_modules/fastq/queue.js199
-rw-r--r--node_modules/fastq/test/example.ts63
-rw-r--r--node_modules/fastq/test/test.js554
-rw-r--r--node_modules/fastq/test/tsconfig.json11
11 files changed, 0 insertions, 1270 deletions
diff --git a/node_modules/fastq/.github/workflows/ci.yml b/node_modules/fastq/.github/workflows/ci.yml
deleted file mode 100644
index d9ee234..0000000
--- a/node_modules/fastq/.github/workflows/ci.yml
+++ /dev/null
@@ -1,50 +0,0 @@
-name: ci
-
-on: [push, pull_request]
-
-jobs:
- legacy:
- runs-on: ubuntu-latest
-
- strategy:
- matrix:
- node-version: ['0.10', '0.12', 4.x, 6.x, 8.x]
-
- steps:
- - uses: actions/checkout@v2
-
- - name: Use Node.js
- uses: actions/setup-node@v1
- with:
- node-version: ${{ matrix.node-version }}
-
- - name: Install
- run: |
- npm install --production && npm install tape
-
- - name: Run tests
- run: |
- npm run legacy
-
- test:
- runs-on: ubuntu-latest
-
- strategy:
- matrix:
- node-version: [10.x, 12.x, 13.x, 14.x, 15.x]
-
- steps:
- - uses: actions/checkout@v2
-
- - name: Use Node.js
- uses: actions/setup-node@v1
- with:
- node-version: ${{ matrix.node-version }}
-
- - name: Install
- run: |
- npm install
-
- - name: Run tests
- run: |
- npm run test
diff --git a/node_modules/fastq/LICENSE b/node_modules/fastq/LICENSE
deleted file mode 100644
index 27c7bb4..0000000
--- a/node_modules/fastq/LICENSE
+++ /dev/null
@@ -1,13 +0,0 @@
-Copyright (c) 2015-2020, Matteo Collina <matteo.collina@gmail.com>
-
-Permission to use, copy, modify, and/or distribute this software for any
-purpose with or without fee is hereby granted, provided that the above
-copyright notice and this permission notice appear in all copies.
-
-THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
-WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
-MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
-ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
-WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
-ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
-OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
diff --git a/node_modules/fastq/README.md b/node_modules/fastq/README.md
deleted file mode 100644
index 93a98b6..0000000
--- a/node_modules/fastq/README.md
+++ /dev/null
@@ -1,208 +0,0 @@
-# fastq
-
-![ci][ci-url]
-[![npm version][npm-badge]][npm-url]
-[![Dependency Status][david-badge]][david-url]
-
-Fast, in memory work queue. `fastq` is API compatible with
-[`async.queue`](https://github.com/caolan/async#queueworker-concurrency)
-
-Benchmarks (1 million tasks):
-
-* setImmediate: 812ms
-* fastq: 854ms
-* async.queue: 1298ms
-* neoAsync.queue: 1249ms
-
-Obtained on node 12.16.1, on a dedicated server.
-
-If you need zero-overhead series function call, check out
-[fastseries](http://npm.im/fastseries). For zero-overhead parallel
-function call, check out [fastparallel](http://npm.im/fastparallel).
-
-[![js-standard-style](https://raw.githubusercontent.com/feross/standard/master/badge.png)](https://github.com/feross/standard)
-
- * <a href="#install">Installation</a>
- * <a href="#usage">Usage</a>
- * <a href="#api">API</a>
- * <a href="#license">Licence &amp; copyright</a>
-
-## Install
-
-`npm i fastq --save`
-
-## Usage
-
-```js
-'use strict'
-
-var queue = require('fastq')(worker, 1)
-
-queue.push(42, function (err, result) {
- if (err) { throw err }
- console.log('the result is', result)
-})
-
-function worker (arg, cb) {
- cb(null, 42 * 2)
-}
-```
-
-### Setting this
-
-```js
-'use strict'
-
-var that = { hello: 'world' }
-var queue = require('fastq')(that, worker, 1)
-
-queue.push(42, function (err, result) {
- if (err) { throw err }
- console.log(this)
- console.log('the result is', result)
-})
-
-function worker (arg, cb) {
- console.log(this)
- cb(null, 42 * 2)
-}
-```
-
-## API
-
-* <a href="#fastqueue"><code>fastqueue()</code></a>
-* <a href="#push"><code>queue#<b>push()</b></code></a>
-* <a href="#unshift"><code>queue#<b>unshift()</b></code></a>
-* <a href="#pause"><code>queue#<b>pause()</b></code></a>
-* <a href="#resume"><code>queue#<b>resume()</b></code></a>
-* <a href="#idle"><code>queue#<b>idle()</b></code></a>
-* <a href="#length"><code>queue#<b>length()</b></code></a>
-* <a href="#getQueue"><code>queue#<b>getQueue()</b></code></a>
-* <a href="#kill"><code>queue#<b>kill()</b></code></a>
-* <a href="#killAndDrain"><code>queue#<b>killAndDrain()</b></code></a>
-* <a href="#error"><code>queue#<b>error()</b></code></a>
-* <a href="#concurrency"><code>queue#<b>concurrency</b></code></a>
-* <a href="#drain"><code>queue#<b>drain</b></code></a>
-* <a href="#empty"><code>queue#<b>empty</b></code></a>
-* <a href="#saturated"><code>queue#<b>saturated</b></code></a>
-
--------------------------------------------------------
-<a name="fastqueue"></a>
-### fastqueue([that], worker, concurrency)
-
-Creates a new queue.
-
-Arguments:
-
-* `that`, optional context of the `worker` function.
-* `worker`, worker function, it would be called with `that` as `this`,
- if that is specified.
-* `concurrency`, number of concurrent tasks that could be executed in
- parallel.
-
--------------------------------------------------------
-<a name="push"></a>
-### queue.push(task, done)
-
-Add a task at the end of the queue. `done(err, result)` will be called
-when the task was processed.
-
--------------------------------------------------------
-<a name="unshift"></a>
-### queue.unshift(task, done)
-
-Add a task at the beginning of the queue. `done(err, result)` will be called
-when the task was processed.
-
--------------------------------------------------------
-<a name="pause"></a>
-### queue.pause()
-
-Pause the processing of tasks. Currently worked tasks are not
-stopped.
-
--------------------------------------------------------
-<a name="resume"></a>
-### queue.resume()
-
-Resume the processing of tasks.
-
--------------------------------------------------------
-<a name="idle"></a>
-### queue.idle()
-
-Returns `false` if there are tasks being processed or waiting to be processed.
-`true` otherwise.
-
--------------------------------------------------------
-<a name="length"></a>
-### queue.length()
-
-Returns the number of tasks waiting to be processed (in the queue).
-
--------------------------------------------------------
-<a name="getQueue"></a>
-### queue.getQueue()
-
-Returns all the tasks be processed (in the queue). Returns empty array when there are no tasks
-
--------------------------------------------------------
-<a name="kill"></a>
-### queue.kill()
-
-Removes all tasks waiting to be processed, and reset `drain` to an empty
-function.
-
--------------------------------------------------------
-<a name="killAndDrain"></a>
-### queue.killAndDrain()
-
-Same than `kill` but the `drain` function will be called before reset to empty.
-
--------------------------------------------------------
-<a name="error"></a>
-### queue.error(handler)
-
-Set a global error handler. `handler(err, task)` will be called
-when any of the tasks return an error.
-
--------------------------------------------------------
-<a name="concurrency"></a>
-### queue.concurrency
-
-Property that returns the number of concurrent tasks that could be executed in
-parallel. It can be altered at runtime.
-
--------------------------------------------------------
-<a name="drain"></a>
-### queue.drain
-
-Function that will be called when the last
-item from the queue has been processed by a worker.
-It can be altered at runtime.
-
--------------------------------------------------------
-<a name="empty"></a>
-### queue.empty
-
-Function that will be called when the last
-item from the queue has been assigned to a worker.
-It can be altered at runtime.
-
--------------------------------------------------------
-<a name="saturated"></a>
-### queue.saturated
-
-Function that will be called when the queue hits the concurrency
-limit.
-It can be altered at runtime.
-
-## License
-
-ISC
-
-[ci-url]: https://github.com/mcollina/fastq/workflows/ci/badge.svg
-[npm-badge]: https://badge.fury.io/js/fastq.svg
-[npm-url]: https://badge.fury.io/js/fastq
-[david-badge]: https://david-dm.org/mcollina/fastq.svg
-[david-url]: https://david-dm.org/mcollina/fastq
diff --git a/node_modules/fastq/bench.js b/node_modules/fastq/bench.js
deleted file mode 100644
index 931539d..0000000
--- a/node_modules/fastq/bench.js
+++ /dev/null
@@ -1,58 +0,0 @@
-'use strict'
-
-var max = 1000000
-var fastqueue = require('./')(worker, 1)
-var async = require('async')
-var neo = require('neo-async')
-var asyncqueue = async.queue(worker, 1)
-var neoqueue = neo.queue(worker, 1)
-
-function bench (func, done) {
- var key = max + '*' + func.name
- var count = -1
-
- console.time(key)
- end()
-
- function end () {
- if (++count < max) {
- func(end)
- } else {
- console.timeEnd(key)
- if (done) {
- done()
- }
- }
- }
-}
-
-function benchFastQ (done) {
- fastqueue.push(42, done)
-}
-
-function benchAsyncQueue (done) {
- asyncqueue.push(42, done)
-}
-
-function benchNeoQueue (done) {
- neoqueue.push(42, done)
-}
-
-function worker (arg, cb) {
- setImmediate(cb)
-}
-
-function benchSetImmediate (cb) {
- worker(42, cb)
-}
-
-function runBench (done) {
- async.eachSeries([
- benchSetImmediate,
- benchFastQ,
- benchNeoQueue,
- benchAsyncQueue
- ], bench, done)
-}
-
-runBench(runBench)
diff --git a/node_modules/fastq/example.js b/node_modules/fastq/example.js
deleted file mode 100644
index 4f834c4..0000000
--- a/node_modules/fastq/example.js
+++ /dev/null
@@ -1,12 +0,0 @@
-'use strict'
-
-var queue = require('./')(worker, 1)
-
-queue.push(42, function (err, result) {
- if (err) { throw err }
- console.log('the result is', result)
-})
-
-function worker (arg, cb) {
- cb(null, 42 * 2)
-}
diff --git a/node_modules/fastq/index.d.ts b/node_modules/fastq/index.d.ts
deleted file mode 100644
index 31e7b79..0000000
--- a/node_modules/fastq/index.d.ts
+++ /dev/null
@@ -1,27 +0,0 @@
-declare function fastq<C, T = any, R = any>(context: C, worker: fastq.worker<C, T, R>, concurrency: number): fastq.queue<T, R>
-declare function fastq<C, T = any, R = any>(worker: fastq.worker<C, T, R>, concurrency: number): fastq.queue<T, R>
-
-declare namespace fastq {
- type worker<C, T = any, R = any> = (this: C, task: T, cb: fastq.done<R>) => void
- type done<R = any> = (err: Error | null, result?: R) => void
- type errorHandler<T = any> = (err: Error, task: T) => void
-
- interface queue<T = any, R = any> {
- push(task: T, done: done<R>): void
- unshift(task: T, done: done<R>): void
- pause(): any
- resume(): any
- idle(): boolean
- length(): number
- getQueue(): T[]
- kill(): any
- killAndDrain(): any
- error(handler: errorHandler): void
- concurrency: number
- drain(): any
- empty: () => void
- saturated: () => void
- }
-}
-
-export = fastq
diff --git a/node_modules/fastq/package.json b/node_modules/fastq/package.json
deleted file mode 100644
index 6ee8ad9..0000000
--- a/node_modules/fastq/package.json
+++ /dev/null
@@ -1,75 +0,0 @@
-{
- "_from": "fastq@^1.6.0",
- "_id": "fastq@1.9.0",
- "_inBundle": false,
- "_integrity": "sha512-i7FVWL8HhVY+CTkwFxkN2mk3h+787ixS5S63eb78diVRc1MCssarHq3W5cj0av7YDSwmaV928RNag+U1etRQ7w==",
- "_location": "/fastq",
- "_phantomChildren": {},
- "_requested": {
- "type": "range",
- "registry": true,
- "raw": "fastq@^1.6.0",
- "name": "fastq",
- "escapedName": "fastq",
- "rawSpec": "^1.6.0",
- "saveSpec": null,
- "fetchSpec": "^1.6.0"
- },
- "_requiredBy": [
- "/@nodelib/fs.walk"
- ],
- "_resolved": "https://registry.npmjs.org/fastq/-/fastq-1.9.0.tgz",
- "_shasum": "e16a72f338eaca48e91b5c23593bcc2ef66b7947",
- "_spec": "fastq@^1.6.0",
- "_where": "/home/pruss/Dev/3-minute-website/node_modules/@nodelib/fs.walk",
- "author": {
- "name": "Matteo Collina",
- "email": "hello@matteocollina.com"
- },
- "bugs": {
- "url": "https://github.com/mcollina/fastq/issues"
- },
- "bundleDependencies": false,
- "dependencies": {
- "reusify": "^1.0.4"
- },
- "deprecated": false,
- "description": "Fast, in memory work queue",
- "devDependencies": {
- "async": "^3.1.0",
- "neo-async": "^2.6.1",
- "nyc": "^15.0.0",
- "pre-commit": "^1.2.2",
- "snazzy": "^8.0.0",
- "standard": "^15.0.0",
- "tape": "^5.0.0",
- "typescript": "^4.0.2"
- },
- "homepage": "https://github.com/mcollina/fastq#readme",
- "keywords": [
- "fast",
- "queue",
- "async",
- "worker"
- ],
- "license": "ISC",
- "main": "queue.js",
- "name": "fastq",
- "pre-commit": [
- "test"
- ],
- "repository": {
- "type": "git",
- "url": "git+https://github.com/mcollina/fastq.git"
- },
- "scripts": {
- "coverage": "nyc --reporter=html --reporter=cobertura --reporter=text tape test/test.js",
- "legacy": "tape test/test.js",
- "lint": "standard --verbose | snazzy",
- "test": "npm run lint && npm run unit && npm run typescript",
- "test:report": "npm run lint && npm run unit:report",
- "typescript": "tsc --project ./test/tsconfig.json",
- "unit": "nyc --lines 100 --branches 100 --functions 100 --check-coverage --reporter=text tape test/test.js"
- },
- "version": "1.9.0"
-}
diff --git a/node_modules/fastq/queue.js b/node_modules/fastq/queue.js
deleted file mode 100644
index 397a331..0000000
--- a/node_modules/fastq/queue.js
+++ /dev/null
@@ -1,199 +0,0 @@
-'use strict'
-
-var reusify = require('reusify')
-
-function fastqueue (context, worker, concurrency) {
- if (typeof context === 'function') {
- concurrency = worker
- worker = context
- context = null
- }
-
- var cache = reusify(Task)
- var queueHead = null
- var queueTail = null
- var _running = 0
- var errorHandler = null
-
- var self = {
- push: push,
- drain: noop,
- saturated: noop,
- pause: pause,
- paused: false,
- concurrency: concurrency,
- running: running,
- resume: resume,
- idle: idle,
- length: length,
- getQueue: getQueue,
- unshift: unshift,
- empty: noop,
- kill: kill,
- killAndDrain: killAndDrain,
- error: error
- }
-
- return self
-
- function running () {
- return _running
- }
-
- function pause () {
- self.paused = true
- }
-
- function length () {
- var current = queueHead
- var counter = 0
-
- while (current) {
- current = current.next
- counter++
- }
-
- return counter
- }
-
- function getQueue () {
- var current = queueHead
- var tasks = []
-
- while (current) {
- tasks.push(current.value)
- current = current.next
- }
-
- return tasks
- }
-
- function resume () {
- if (!self.paused) return
- self.paused = false
- for (var i = 0; i < self.concurrency; i++) {
- _running++
- release()
- }
- }
-
- function idle () {
- return _running === 0 && self.length() === 0
- }
-
- function push (value, done) {
- var current = cache.get()
-
- current.context = context
- current.release = release
- current.value = value
- current.callback = done || noop
- current.errorHandler = errorHandler
-
- if (_running === self.concurrency || self.paused) {
- if (queueTail) {
- queueTail.next = current
- queueTail = current
- } else {
- queueHead = current
- queueTail = current
- self.saturated()
- }
- } else {
- _running++
- worker.call(context, current.value, current.worked)
- }
- }
-
- function unshift (value, done) {
- var current = cache.get()
-
- current.context = context
- current.release = release
- current.value = value
- current.callback = done || noop
-
- if (_running === self.concurrency || self.paused) {
- if (queueHead) {
- current.next = queueHead
- queueHead = current
- } else {
- queueHead = current
- queueTail = current
- self.saturated()
- }
- } else {
- _running++
- worker.call(context, current.value, current.worked)
- }
- }
-
- function release (holder) {
- if (holder) {
- cache.release(holder)
- }
- var next = queueHead
- if (next) {
- if (!self.paused) {
- if (queueTail === queueHead) {
- queueTail = null
- }
- queueHead = next.next
- next.next = null
- worker.call(context, next.value, next.worked)
- if (queueTail === null) {
- self.empty()
- }
- } else {
- _running--
- }
- } else if (--_running === 0) {
- self.drain()
- }
- }
-
- function kill () {
- queueHead = null
- queueTail = null
- self.drain = noop
- }
-
- function killAndDrain () {
- queueHead = null
- queueTail = null
- self.drain()
- self.drain = noop
- }
-
- function error (handler) {
- errorHandler = handler
- }
-}
-
-function noop () {}
-
-function Task () {
- this.value = null
- this.callback = noop
- this.next = null
- this.release = noop
- this.context = null
- this.errorHandler = null
-
- var self = this
-
- this.worked = function worked (err, result) {
- var callback = self.callback
- var errorHandler = self.errorHandler
- var val = self.value
- self.value = null
- self.callback = noop
- if (self.errorHandler) {
- errorHandler(err, val)
- }
- callback.call(self.context, err, result)
- self.release(self)
- }
-}
-
-module.exports = fastqueue
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))
-}
diff --git a/node_modules/fastq/test/test.js b/node_modules/fastq/test/test.js
deleted file mode 100644
index 5e660f4..0000000
--- a/node_modules/fastq/test/test.js
+++ /dev/null
@@ -1,554 +0,0 @@
-'use strict'
-
-var test = require('tape')
-var buildQueue = require('../')
-
-test('worker execution', function (t) {
- t.plan(3)
-
- var queue = buildQueue(worker, 1)
-
- queue.push(42, function (err, result) {
- t.error(err, 'no error')
- t.equal(result, true, 'result matches')
- })
-
- function worker (arg, cb) {
- t.equal(arg, 42)
- cb(null, true)
- }
-})
-
-test('limit', function (t) {
- t.plan(4)
-
- var expected = [10, 0]
- var queue = buildQueue(worker, 1)
-
- queue.push(10, result)
- queue.push(0, result)
-
- function result (err, arg) {
- t.error(err, 'no error')
- t.equal(arg, expected.shift(), 'the result matches')
- }
-
- function worker (arg, cb) {
- setTimeout(cb, arg, null, arg)
- }
-})
-
-test('multiple executions', function (t) {
- t.plan(15)
-
- var queue = buildQueue(worker, 1)
- var toExec = [1, 2, 3, 4, 5]
- var count = 0
-
- toExec.forEach(function (task) {
- queue.push(task, done)
- })
-
- function done (err, result) {
- t.error(err, 'no error')
- t.equal(result, toExec[count - 1], 'the result matches')
- }
-
- function worker (arg, cb) {
- t.equal(arg, toExec[count], 'arg matches')
- count++
- setImmediate(cb, null, arg)
- }
-})
-
-test('multiple executions, one after another', function (t) {
- t.plan(15)
-
- var queue = buildQueue(worker, 1)
- var toExec = [1, 2, 3, 4, 5]
- var count = 0
-
- queue.push(toExec[0], done)
-
- function done (err, result) {
- t.error(err, 'no error')
- t.equal(result, toExec[count - 1], 'the result matches')
- if (count < toExec.length) {
- queue.push(toExec[count], done)
- }
- }
-
- function worker (arg, cb) {
- t.equal(arg, toExec[count], 'arg matches')
- count++
- setImmediate(cb, null, arg)
- }
-})
-
-test('set this', function (t) {
- t.plan(3)
-
- var that = {}
- var queue = buildQueue(that, worker, 1)
-
- queue.push(42, function (err, result) {
- t.error(err, 'no error')
- t.equal(this, that, 'this matches')
- })
-
- function worker (arg, cb) {
- t.equal(this, that, 'this matches')
- cb(null, true)
- }
-})
-
-test('drain', function (t) {
- t.plan(4)
-
- var queue = buildQueue(worker, 1)
- var worked = false
-
- queue.push(42, function (err, result) {
- t.error(err, 'no error')
- t.equal(result, true, 'result matches')
- })
-
- queue.drain = function () {
- t.equal(true, worked, 'drained')
- }
-
- function worker (arg, cb) {
- t.equal(arg, 42)
- worked = true
- setImmediate(cb, null, true)
- }
-})
-
-test('pause && resume', function (t) {
- t.plan(7)
-
- var queue = buildQueue(worker, 1)
- var worked = false
-
- t.notOk(queue.paused, 'it should not be paused')
-
- queue.pause()
-
- queue.push(42, function (err, result) {
- t.error(err, 'no error')
- t.equal(result, true, 'result matches')
- })
-
- t.notOk(worked, 'it should be paused')
- t.ok(queue.paused, 'it should be paused')
-
- queue.resume()
- queue.resume() // second resume is a no-op
-
- t.notOk(queue.paused, 'it should not be paused')
-
- function worker (arg, cb) {
- t.equal(arg, 42)
- worked = true
- cb(null, true)
- }
-})
-
-test('pause in flight && resume', function (t) {
- t.plan(9)
-
- var queue = buildQueue(worker, 1)
- var expected = [42, 24]
-
- t.notOk(queue.paused, 'it should not be paused')
-
- queue.push(42, function (err, result) {
- t.error(err, 'no error')
- t.equal(result, true, 'result matches')
- t.ok(queue.paused, 'it should be paused')
- process.nextTick(function () { queue.resume() })
- })
-
- queue.push(24, function (err, result) {
- t.error(err, 'no error')
- t.equal(result, true, 'result matches')
- t.notOk(queue.paused, 'it should not be paused')
- })
-
- queue.pause()
-
- function worker (arg, cb) {
- t.equal(arg, expected.shift())
- process.nextTick(function () { cb(null, true) })
- }
-})
-
-test('altering concurrency', function (t) {
- t.plan(7)
-
- var queue = buildQueue(worker, 1)
- var count = 0
-
- queue.pause()
-
- queue.push(24, workDone)
- queue.push(24, workDone)
-
- queue.concurrency = 2
-
- queue.resume()
-
- t.equal(queue.running(), 2, '2 jobs running')
-
- function workDone (err, result) {
- t.error(err, 'no error')
- t.equal(result, true, 'result matches')
- }
-
- function worker (arg, cb) {
- t.equal(0, count, 'works in parallel')
- setImmediate(function () {
- count++
- cb(null, true)
- })
- }
-})
-
-test('idle()', function (t) {
- t.plan(12)
-
- var queue = buildQueue(worker, 1)
-
- t.ok(queue.idle(), 'queue is idle')
-
- queue.push(42, function (err, result) {
- t.error(err, 'no error')
- t.equal(result, true, 'result matches')
- t.notOk(queue.idle(), 'queue is not idle')
- })
-
- queue.push(42, function (err, result) {
- t.error(err, 'no error')
- t.equal(result, true, 'result matches')
- // it will go idle after executing this function
- setImmediate(function () {
- t.ok(queue.idle(), 'queue is now idle')
- })
- })
-
- t.notOk(queue.idle(), 'queue is not idle')
-
- function worker (arg, cb) {
- t.notOk(queue.idle(), 'queue is not idle')
- t.equal(arg, 42)
- setImmediate(cb, null, true)
- }
-})
-
-test('saturated', function (t) {
- t.plan(9)
-
- var queue = buildQueue(worker, 1)
- var preworked = 0
- var worked = 0
-
- queue.saturated = function () {
- t.pass('saturated')
- t.equal(preworked, 1, 'started 1 task')
- t.equal(worked, 0, 'worked zero task')
- }
-
- queue.push(42, done)
- queue.push(42, done)
-
- function done (err, result) {
- t.error(err, 'no error')
- t.equal(result, true, 'result matches')
- }
-
- function worker (arg, cb) {
- t.equal(arg, 42)
- preworked++
- setImmediate(function () {
- worked++
- cb(null, true)
- })
- }
-})
-
-test('length', function (t) {
- t.plan(7)
-
- var queue = buildQueue(worker, 1)
-
- t.equal(queue.length(), 0, 'nothing waiting')
- queue.push(42, done)
- t.equal(queue.length(), 0, 'nothing waiting')
- queue.push(42, done)
- t.equal(queue.length(), 1, 'one task waiting')
- queue.push(42, done)
- t.equal(queue.length(), 2, 'two tasks waiting')
-
- function done (err, result) {
- t.error(err, 'no error')
- }
-
- function worker (arg, cb) {
- setImmediate(function () {
- cb(null, true)
- })
- }
-})
-
-test('getQueue', function (t) {
- t.plan(10)
-
- var queue = buildQueue(worker, 1)
-
- t.equal(queue.getQueue().length, 0, 'nothing waiting')
- queue.push(42, done)
- t.equal(queue.getQueue().length, 0, 'nothing waiting')
- queue.push(42, done)
- t.equal(queue.getQueue().length, 1, 'one task waiting')
- t.equal(queue.getQueue()[0], 42, 'should be equal')
- queue.push(43, done)
- t.equal(queue.getQueue().length, 2, 'two tasks waiting')
- t.equal(queue.getQueue()[0], 42, 'should be equal')
- t.equal(queue.getQueue()[1], 43, 'should be equal')
-
- function done (err, result) {
- t.error(err, 'no error')
- }
-
- function worker (arg, cb) {
- setImmediate(function () {
- cb(null, true)
- })
- }
-})
-
-test('unshift', function (t) {
- t.plan(8)
-
- var queue = buildQueue(worker, 1)
- var expected = [1, 2, 3, 4]
-
- queue.push(1, done)
- queue.push(4, done)
- queue.unshift(3, done)
- queue.unshift(2, done)
-
- function done (err, result) {
- t.error(err, 'no error')
- }
-
- function worker (arg, cb) {
- t.equal(expected.shift(), arg, 'tasks come in order')
- setImmediate(function () {
- cb(null, true)
- })
- }
-})
-
-test('unshift && empty', function (t) {
- t.plan(2)
-
- var queue = buildQueue(worker, 1)
- var completed = false
-
- queue.pause()
-
- queue.empty = function () {
- t.notOk(completed, 'the task has not completed yet')
- }
-
- queue.unshift(1, done)
-
- queue.resume()
-
- function done (err, result) {
- completed = true
- t.error(err, 'no error')
- }
-
- function worker (arg, cb) {
- setImmediate(function () {
- cb(null, true)
- })
- }
-})
-
-test('push && empty', function (t) {
- t.plan(2)
-
- var queue = buildQueue(worker, 1)
- var completed = false
-
- queue.pause()
-
- queue.empty = function () {
- t.notOk(completed, 'the task has not completed yet')
- }
-
- queue.push(1, done)
-
- queue.resume()
-
- function done (err, result) {
- completed = true
- t.error(err, 'no error')
- }
-
- function worker (arg, cb) {
- setImmediate(function () {
- cb(null, true)
- })
- }
-})
-
-test('kill', function (t) {
- t.plan(5)
-
- var queue = buildQueue(worker, 1)
- var expected = [1]
-
- var predrain = queue.drain
-
- queue.drain = function drain () {
- t.fail('drain should never be called')
- }
-
- queue.push(1, done)
- queue.push(4, done)
- queue.unshift(3, done)
- queue.unshift(2, done)
- queue.kill()
-
- function done (err, result) {
- t.error(err, 'no error')
- setImmediate(function () {
- t.equal(queue.length(), 0, 'no queued tasks')
- t.equal(queue.running(), 0, 'no running tasks')
- t.equal(queue.drain, predrain, 'drain is back to default')
- })
- }
-
- function worker (arg, cb) {
- t.equal(expected.shift(), arg, 'tasks come in order')
- setImmediate(function () {
- cb(null, true)
- })
- }
-})
-
-test('killAndDrain', function (t) {
- t.plan(6)
-
- var queue = buildQueue(worker, 1)
- var expected = [1]
-
- var predrain = queue.drain
-
- queue.drain = function drain () {
- t.pass('drain has been called')
- }
-
- queue.push(1, done)
- queue.push(4, done)
- queue.unshift(3, done)
- queue.unshift(2, done)
- queue.killAndDrain()
-
- function done (err, result) {
- t.error(err, 'no error')
- setImmediate(function () {
- t.equal(queue.length(), 0, 'no queued tasks')
- t.equal(queue.running(), 0, 'no running tasks')
- t.equal(queue.drain, predrain, 'drain is back to default')
- })
- }
-
- function worker (arg, cb) {
- t.equal(expected.shift(), arg, 'tasks come in order')
- setImmediate(function () {
- cb(null, true)
- })
- }
-})
-
-test('pause && idle', function (t) {
- t.plan(11)
-
- var queue = buildQueue(worker, 1)
- var worked = false
-
- t.notOk(queue.paused, 'it should not be paused')
- t.ok(queue.idle(), 'should be idle')
-
- queue.pause()
-
- queue.push(42, function (err, result) {
- t.error(err, 'no error')
- t.equal(result, true, 'result matches')
- })
-
- t.notOk(worked, 'it should be paused')
- t.ok(queue.paused, 'it should be paused')
- t.notOk(queue.idle(), 'should not be idle')
-
- queue.resume()
-
- t.notOk(queue.paused, 'it should not be paused')
- t.notOk(queue.idle(), 'it should not be idle')
-
- function worker (arg, cb) {
- t.equal(arg, 42)
- worked = true
- process.nextTick(cb.bind(null, null, true))
- process.nextTick(function () {
- t.ok(queue.idle(), 'is should be idle')
- })
- }
-})
-
-test('push without cb', function (t) {
- t.plan(1)
-
- var queue = buildQueue(worker, 1)
-
- queue.push(42)
-
- function worker (arg, cb) {
- t.equal(arg, 42)
- cb()
- }
-})
-
-test('unshift without cb', function (t) {
- t.plan(1)
-
- var queue = buildQueue(worker, 1)
-
- queue.unshift(42)
-
- function worker (arg, cb) {
- t.equal(arg, 42)
- cb()
- }
-})
-
-test('push with worker throwing error', function (t) {
- t.plan(5)
- var q = buildQueue(function (task, cb) {
- cb(new Error('test error'), null)
- }, 1)
- q.error(function (err, task) {
- t.ok(err instanceof Error, 'global error handler should catch the error')
- t.match(err.message, /test error/, 'error message should be "test error"')
- t.equal(task, 42, 'The task executed should be passed')
- })
- q.push(42, function (err) {
- t.ok(err instanceof Error, 'push callback should catch the error')
- t.match(err.message, /test error/, 'error message should be "test error"')
- })
-})
diff --git a/node_modules/fastq/test/tsconfig.json b/node_modules/fastq/test/tsconfig.json
deleted file mode 100644
index 66e16e9..0000000
--- a/node_modules/fastq/test/tsconfig.json
+++ /dev/null
@@ -1,11 +0,0 @@
-{
- "compilerOptions": {
- "target": "es6",
- "module": "commonjs",
- "noEmit": true,
- "strict": true
- },
- "files": [
- "./example.ts"
- ]
-}