Changeset e29cc2e for trip-planner-front/node_modules/p-limit/index.js

Timestamp:

11/25/21 22:08:24 (3 years ago)

Author:

Ema <ema_spirova@…>

Branches:

master

Children:

8d391a1

Parents:

59329aa

Message:

primeNG components

File:

• trip-planner-front/node_modules/p-limit/index.js (modified) (4 diffs)

trip-planner-front/node_modules/p-limit/index.js

@@ -1 +1 @@
 'use strict';
-const Queue = require('yocto-queue');
+const pTry = require('p-try');
 
 const pLimit = concurrency => {
         if (!((Number.isInteger(concurrency) || concurrency === Infinity) && concurrency > 0)) {
-                throw new TypeError('Expected `concurrency` to be a number from 1 and up');
+                return Promise.reject(new TypeError('Expected `concurrency` to be a number from 1 and up'));
         }
 
-        const queue = new Queue();
+        const queue = [];
         let activeCount = 0;
 
@@ -13 +13 @@
                 activeCount--;
 
-                if (queue.size > 0) {
-                        queue.dequeue()();
+                if (queue.length > 0) {
+                        queue.shift()();
                 }
         };
 
-        const run = async (fn, resolve, ...args) => {
+        const run = (fn, resolve, ...args) => {
                 activeCount++;
 
-                const result = (async () => fn(...args))();
+                const result = pTry(fn, ...args);
 
                 resolve(result);
 
-                try {
-                        await result;
-                } catch {}
-
-                next();
+                result.then(next, next);
         };
 
         const enqueue = (fn, resolve, ...args) => {
-                queue.enqueue(run.bind(null, fn, resolve, ...args));
-
-                (async () => {
-                        // This function needs to wait until the next microtask before comparing
-                        // `activeCount` to `concurrency`, because `activeCount` is updated asynchronously
-                        // when the run function is dequeued and called. The comparison in the if-statement
-                        // needs to happen asynchronously as well to get an up-to-date value for `activeCount`.
-                        await Promise.resolve();
-
-                        if (activeCount < concurrency && queue.size > 0) {
-                                queue.dequeue()();
-                        }
-                })();
+                if (activeCount < concurrency) {
+                        run(fn, resolve, ...args);
+                } else {
+                        queue.push(run.bind(null, fn, resolve, ...args));
+                }
         };
 
-        const generator = (fn, ...args) => new Promise(resolve => {
-                enqueue(fn, resolve, ...args);
-        });
-
+        const generator = (fn, ...args) => new Promise(resolve => enqueue(fn, resolve, ...args));
         Object.defineProperties(generator, {
                 activeCount: {
@@ -57 +42 @@
                 },
                 pendingCount: {
-                        get: () => queue.size
+                        get: () => queue.length
                 },
                 clearQueue: {
                         value: () => {
-                                queue.clear();
+                                queue.length = 0;
                         }
                 }
@@ -70 +55 @@
 
 module.exports = pLimit;
+module.exports.default = pLimit;