FM / internal

/var/www/myprog.com.ua/server/node/node_modules/async/internal/

/var/www/myprog.com.ua/server/node/node_modules/async/internal

Name	Size	Mode	Actions
applyEach.js	783	0644	edit dl rm
asyncEachOfLimit.js	1976	0644	edit dl rm
awaitify.js	816	0644	edit dl rm
breakLoop.js	254	0644	edit dl rm
consoleFunc.js	919	0644	edit dl rm
createTester.js	1228	0644	edit dl rm
DoublyLinkedList.js	2282	0644	edit dl rm
eachOfLimit.js	2638	0644	edit dl rm
filter.js	1620	0644	edit dl rm
getIterator.js	217	0644	edit dl rm
Heap.js	2497	0644	edit dl rm
initialParams.js	289	0644	edit dl rm
isArrayLike.js	279	0644	edit dl rm
iterator.js	1460	0644	edit dl rm
map.js	761	0644	edit dl rm
once.js	362	0644	edit dl rm
onlyOnce.js	360	0644	edit dl rm
parallel.js	962	0644	edit dl rm
promiseCallback.js	532	0644	edit dl rm
queue.js	8522	0644	edit dl rm
range.js	270	0644	edit dl rm
reject.js	695	0644	edit dl rm
setImmediate.js	857	0644	edit dl rm
withoutIndex.js	251	0644	edit dl rm
wrapAsync.js	955	0644	edit dl rm

Edit: /var/www/myprog.com.ua/server/node/node_modules/async/internal/asyncEachOfLimit.js (1976B)

'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;