summaryrefslogtreecommitdiffstats
path: root/node_modules/mongoose/lib/helpers/parallelLimit.js
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/mongoose/lib/helpers/parallelLimit.js
parent1870f3fdf43707a15fda0f609a021f516f45eb63 (diff)
downloadwebsite_creator-81ddf9b700bc48a1f8e472209f080f9c1d9a9b09.tar.gz
website_creator-81ddf9b700bc48a1f8e472209f080f9c1d9a9b09.tar.bz2
website_creator-81ddf9b700bc48a1f8e472209f080f9c1d9a9b09.zip
rm node_modules
Diffstat (limited to 'node_modules/mongoose/lib/helpers/parallelLimit.js')
-rw-r--r--node_modules/mongoose/lib/helpers/parallelLimit.js55
1 files changed, 0 insertions, 55 deletions
diff --git a/node_modules/mongoose/lib/helpers/parallelLimit.js b/node_modules/mongoose/lib/helpers/parallelLimit.js
deleted file mode 100644
index 9b07c02..0000000
--- a/node_modules/mongoose/lib/helpers/parallelLimit.js
+++ /dev/null
@@ -1,55 +0,0 @@
-'use strict';
-
-module.exports = parallelLimit;
-
-/*!
- * ignore
- */
-
-function parallelLimit(fns, limit, callback) {
- let numInProgress = 0;
- let numFinished = 0;
- let error = null;
-
- if (limit <= 0) {
- throw new Error('Limit must be positive');
- }
-
- if (fns.length === 0) {
- return callback(null, []);
- }
-
- for (let i = 0; i < fns.length && i < limit; ++i) {
- _start();
- }
-
- function _start() {
- fns[numFinished + numInProgress](_done(numFinished + numInProgress));
- ++numInProgress;
- }
-
- const results = [];
-
- function _done(index) {
- return (err, res) => {
- --numInProgress;
- ++numFinished;
-
- if (error != null) {
- return;
- }
- if (err != null) {
- error = err;
- return callback(error);
- }
-
- results[index] = res;
-
- if (numFinished === fns.length) {
- return callback(null, results);
- } else if (numFinished + numInProgress < fns.length) {
- _start();
- }
- };
- }
-}