feat: initial commit

node_modules/p-limit/index.js

@@ -1,51 +1,66 @@
 'use strict';
-const pTry = require('p-try');
+const Queue = require('yocto-queue');
 
 const pLimit = concurrency => {
 	if (!((Number.isInteger(concurrency) || concurrency === Infinity) && concurrency > 0)) {
-		return Promise.reject(new TypeError('Expected `concurrency` to be a number from 1 and up'));
+		throw new TypeError('Expected `concurrency` to be a number from 1 and up');
 	}
 
-	const queue = [];
+	const queue = new Queue();
 	let activeCount = 0;
 
 	const next = () => {
 		activeCount--;
 
-		if (queue.length > 0) {
-			queue.shift()();
+		if (queue.size > 0) {
+			queue.dequeue()();
 		}
 	};
 
-	const run = (fn, resolve, ...args) => {
+	const run = async (fn, resolve, ...args) => {
 		activeCount++;
 
-		const result = pTry(fn, ...args);
+		const result = (async () => fn(...args))();
 
 		resolve(result);
 
-		result.then(next, next);
+		try {
+			await result;
+		} catch {}
+
+		next();
 	};
 
 	const enqueue = (fn, resolve, ...args) => {
-		if (activeCount < concurrency) {
-			run(fn, resolve, ...args);
-		} else {
-			queue.push(run.bind(null, 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()();
+			}
+		})();
 	};
 
-	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: {
 			get: () => activeCount
 		},
 		pendingCount: {
-			get: () => queue.length
+			get: () => queue.size
 		},
 		clearQueue: {
 			value: () => {
-				queue.length = 0;
+				queue.clear();
 			}
 		}
 	});
@@ -54,4 +69,3 @@ const pLimit = concurrency => {
 };
 
 module.exports = pLimit;
-module.exports.default = pLimit;