Gecko [ unitednationsplay.com ]

Linux unitednationsplay.com 3.10.0-1160.45.1.el7.x86_64 #1 SMP Wed Oct 13 17:20:51 UTC 2021 x86_64
nginx/1.20.1
Server IP : 188.130.139.92 & Your IP : 18.217.230.80
Domains : Cant Read [ /etc/named.conf ]
User : web

Name	Size	Permission	Date
index.js	1.21 KB	-rw-r--r--	2017-09-12 05:30
license	1.08 KB	-rw-r--r--	2017-06-01 19:17
package.json	1.67 KB	-rw-r--r--	2021-02-04 21:24
readme.md	2.15 KB	-rw-r--r--	2017-09-12 05:32

Rename

'use strict';
module.exports = (iterable, mapper, opts) => new Promise((resolve, reject) => {
	opts = Object.assign({
		concurrency: Infinity
	}, opts);

if (typeof mapper !== 'function') {
		throw new TypeError('Mapper function is required');
	}

const concurrency = opts.concurrency;

if (!(typeof concurrency === 'number' && concurrency >= 1)) {
		throw new TypeError(`Expected \`concurrency\` to be a number from 1 and up, got \`${concurrency}\` (${typeof concurrency})`);
	}

const ret = [];
	const iterator = iterable[Symbol.iterator]();
	let isRejected = false;
	let iterableDone = false;
	let resolvingCount = 0;
	let currentIdx = 0;

const next = () => {
		if (isRejected) {
			return;
		}

const nextItem = iterator.next();
		const i = currentIdx;
		currentIdx++;

if (nextItem.done) {
			iterableDone = true;

if (resolvingCount === 0) {
				resolve(ret);
			}

return;
		}

resolvingCount++;

Promise.resolve(nextItem.value)
			.then(el => mapper(el, i))
			.then(
				val => {
					ret[i] = val;
					resolvingCount--;
					next();
				},
				err => {
					isRejected = true;
					reject(err);
				}
			);
	};

for (let i = 0; i < concurrency; i++) {
		next();

if (iterableDone) {
			break;
		}
	}
});