FM / internal

/var/www/greso.tech/server/nsm/node_modules/async/internal/

/var/www/greso.tech/server/nsm/node_modules/async/internal

Name	Size	Mode	Actions
applyEach.js	786	0644	edit dl rm
asyncEachOfLimit.js	1979	0644	edit dl rm
awaitify.js	796	0644	edit dl rm
breakLoop.js	255	0644	edit dl rm
consoleFunc.js	922	0644	edit dl rm
createTester.js	1231	0644	edit dl rm
DoublyLinkedList.js	2285	0644	edit dl rm
eachOfLimit.js	2641	0644	edit dl rm
filter.js	1623	0644	edit dl rm
getIterator.js	220	0644	edit dl rm
Heap.js	2500	0644	edit dl rm
initialParams.js	292	0644	edit dl rm
isArrayLike.js	282	0644	edit dl rm
iterator.js	1463	0644	edit dl rm
map.js	764	0644	edit dl rm
once.js	365	0644	edit dl rm
onlyOnce.js	363	0644	edit dl rm
parallel.js	965	0644	edit dl rm
promiseCallback.js	532	0644	edit dl rm
queue.js	8525	0644	edit dl rm
range.js	273	0644	edit dl rm
reject.js	698	0644	edit dl rm
setImmediate.js	857	0644	edit dl rm
withoutIndex.js	254	0644	edit dl rm
wrapAsync.js	955	0644	edit dl rm

Edit: /var/www/greso.tech/server/nsm/node_modules/async/internal/asyncEachOfLimit.js (1979B)

'use strict';

Object.defineProperty(exports, "__esModule", {
    value: true
});
exports.default = asyncEachOfLimit;

var _breakLoop = require('./breakLoop.js');

var _breakLoop2 = _interopRequireDefault(_breakLoop);

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

// for async generators
function asyncEachOfLimit(generator, limit, iteratee, callback) {
    let done = false;
    let canceled = false;
    let awaiting = false;
    let running = 0;
    let idx = 0;

function iterateeCallback(err, result) {
        //console.log('iterateeCallback')
        running -= 1;
        if (canceled) return;
        if (err) return handleError(err);

if (err === false) {
            done = true;
            canceled = true;
            return;
        }

if (result === _breakLoop2.default || done && running <= 0) {
            done = true;
            //console.log('done iterCb')
            return callback(null);
        }
        replenish();
    }

function handleError(err) {
        if (canceled) return;
        awaiting = false;
        done = true;
        callback(err);
    }

replenish();
}
module.exports = exports['default'];

'use strict'; Object.defineProperty(exports, "__esModule", { value: true }); exports.default = asyncEachOfLimit; var _breakLoop = require('./breakLoop.js'); var _breakLoop2 = _interopRequireDefault(_breakLoop); function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } // for async generators function asyncEachOfLimit(generator, limit, iteratee, callback) { let done = false; let canceled = false; let awaiting = false; let running = 0; let idx = 0; function replenish() { //console.log('replenish') if (running >= limit || awaiting || done) return; //console.log('replenish awaiting') awaiting = true; generator.next().then(({ value, done: iterDone }) => { //console.log('got value', value) if (canceled || done) return; awaiting = false; if (iterDone) { done = true; if (running <= 0) { //console.log('done nextCb') callback(null); } return; } running++; iteratee(value, idx, iterateeCallback); idx++; replenish(); }).catch(handleError); } function iterateeCallback(err, result) { //console.log('iterateeCallback') running -= 1; if (canceled) return; if (err) return handleError(err); if (err === false) { done = true; canceled = true; return; } if (result === _breakLoop2.default || done && running <= 0) { done = true; //console.log('done iterCb') return callback(null); } replenish(); } function handleError(err) { if (canceled) return; awaiting = false; done = true; callback(err); } replenish(); } module.exports = exports['default'];