BLUE

Edit File Size: 1.49 KB

/var/www/uibuilder.cmshelp.dk/httpdocs/node_modules/p-limit/index.js

Text Base64

'use strict';
const Queue = require('yocto-queue');

const pLimit = concurrency => {
	if (!((Number.isInteger(concurrency) || concurrency === Infinity) && concurrency > 0)) {
		throw new TypeError('Expected `concurrency` to be a number from 1 and up');
	}

const queue = new Queue();
	let activeCount = 0;

const next = () => {
		activeCount--;

if (queue.size > 0) {
			queue.dequeue()();
		}
	};

const run = async (fn, resolve, ...args) => {
		activeCount++;

const result = (async () => fn(...args))();

resolve(result);

try {
			await result;
		} catch {}

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()();
			}
		})();
	};

const generator = (fn, ...args) => new Promise(resolve => {
		enqueue(fn, resolve, ...args);
	});

Object.defineProperties(generator, {
		activeCount: {
			get: () => activeCount
		},
		pendingCount: {
			get: () => queue.size
		},
		clearQueue: {
			value: () => {
				queue.clear();
			}
		}
	});

return generator;
};

module.exports = pLimit;

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Name	Size	Perms	Modified	Actions
index.d.ts	1.38 KB	lrw-r--r--	2025-03-28 11:04:36	Edit Download recursive recursive
index.js	1.49 KB	lrw-r--r--	2025-03-28 11:04:36	Edit Download recursive recursive
license	1.09 KB	lrw-r--r--	2025-03-28 11:04:36	Edit Download recursive recursive
package.json	928 B	lrw-r--r--	2025-03-28 11:04:36	Edit Download recursive recursive
readme.md	2.71 KB	lrw-r--r--	2025-03-28 11:04:36	Edit Download recursive recursive

Directory Contents