Software: Apache/2.4.41 (Ubuntu). PHP/8.0.30 

uname -a: Linux apirnd 5.4.0-204-generic #224-Ubuntu SMP Thu Dec 5 13:38:28 UTC 2024 x86_64 

uid=33(www-data) gid=33(www-data) groups=33(www-data) 

Safe-mode: OFF (not secure)

/var/www/html/queuepro/node_modules/ext/promise/   drwxrwxr-x
Free 13.1 GB of 57.97 GB (22.61%)
                            Encoder    Tools    Proc.    FTP brute    Sec.    SQL    PHP-code    Update    Self remove    Logout    

Viewing file:     limit.js (1.47 KB)      -rwxrwxr-x

"use strict";

var ensureNaturalNumber  = require("type/natural-number/ensure")
  , ensurePlainFunction  = require("type/plain-function/ensure")
  , ensure               = require("type/ensure")
  , defineFunctionLength = require("../lib/private/define-function-length");

module.exports = function (limit, callback) {
	limit = ensure(
		["limit", limit, ensureNaturalNumber, { min: 1 }],
		["callback", callback, ensurePlainFunction]
	)[0];

	var Promise = this, ongoingCount = 0, pending = [];
	var onSuccess, onFailure;

	var release = function () {
		--ongoingCount;
		if (ongoingCount >= limit) return;
		var next = pending.shift();
		if (!next) return;
		++ongoingCount;
		try {
			next.resolve(
				Promise.resolve(callback.apply(next.context, next.arguments)).then(
					onSuccess, onFailure
				)
			);
		} catch (exception) {
			release();
			next.reject(exception);
		}
	};

	onSuccess = function (value) {
		release();
		return value;
	};

	onFailure = function (exception) {
		release();
		throw exception;
	};

	return defineFunctionLength(callback.length, function () {
		if (ongoingCount >= limit) {
			var context = this, args = arguments;
			return new Promise(function (resolve, reject) {
				pending.push({
					context: context,
					arguments: args,
					resolve: resolve,
					reject: reject
				});
			});
		}
		++ongoingCount;
		try {
			return Promise.resolve(callback.apply(this, arguments)).then(onSuccess, onFailure);
		} catch (exception) { return onFailure(exception); }
	});
};