Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
DoublyLinkedList.js	2.29 KB	-rw-r--r--	1985-10-26 08:15
applyEach.js	1.03 KB	-rw-r--r--	1985-10-26 08:15
breakLoop.js	226 B	-rw-r--r--	1985-10-26 08:15
consoleFunc.js	1.2 KB	-rw-r--r--	1985-10-26 08:15
createTester.js	1.25 KB	-rw-r--r--	1985-10-26 08:15
doLimit.js	293 B	-rw-r--r--	1985-10-26 08:15
doParallel.js	600 B	-rw-r--r--	1985-10-26 08:15
doParallelLimit.js	653 B	-rw-r--r--	1985-10-26 08:15
eachOfLimit.js	1.96 KB	-rw-r--r--	1985-10-26 08:15
filter.js	2.12 KB	-rw-r--r--	1985-10-26 08:15
findGetResult.js	200 B	-rw-r--r--	1985-10-26 08:15
getIterator.js	307 B	-rw-r--r--	1985-10-26 08:15
initialParams.js	514 B	-rw-r--r--	1985-10-26 08:15
iterator.js	1.43 KB	-rw-r--r--	1985-10-26 08:15
map.js	903 B	-rw-r--r--	1985-10-26 08:15
notId.js	180 B	-rw-r--r--	1985-10-26 08:15
once.js	312 B	-rw-r--r--	1985-10-26 08:15
onlyOnce.js	361 B	-rw-r--r--	1985-10-26 08:15
parallel.js	1.11 KB	-rw-r--r--	1985-10-26 08:15
queue.js	5.64 KB	-rw-r--r--	1985-10-26 08:15
reject.js	541 B	-rw-r--r--	1985-10-26 08:15
setImmediate.js	1021 B	-rw-r--r--	1985-10-26 08:15
slice.js	407 B	-rw-r--r--	1985-10-26 08:15
withoutIndex.js	284 B	-rw-r--r--	1985-10-26 08:15
wrapAsync.js	616 B	-rw-r--r--	1985-10-26 08:15

Rename

'use strict';

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

var _baseIndexOf = require('lodash/_baseIndexOf');

var _baseIndexOf2 = _interopRequireDefault(_baseIndexOf);

var _isArray = require('lodash/isArray');

var _isArray2 = _interopRequireDefault(_isArray);

var _noop = require('lodash/noop');

var _noop2 = _interopRequireDefault(_noop);

var _onlyOnce = require('./onlyOnce');

var _onlyOnce2 = _interopRequireDefault(_onlyOnce);

var _setImmediate = require('./setImmediate');

var _setImmediate2 = _interopRequireDefault(_setImmediate);

var _DoublyLinkedList = require('./DoublyLinkedList');

var _DoublyLinkedList2 = _interopRequireDefault(_DoublyLinkedList);

var _wrapAsync = require('./wrapAsync');

var _wrapAsync2 = _interopRequireDefault(_wrapAsync);

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

function queue(worker, concurrency, payload) {
    if (concurrency == null) {
        concurrency = 1;
    } else if (concurrency === 0) {
        throw new Error('Concurrency must not be zero');
    }

var _worker = (0, _wrapAsync2.default)(worker);
    var numRunning = 0;
    var workersList = [];

for (var i = 0, l = data.length; i < l; i++) {
            var item = {
                data: data[i],
                callback: callback || _noop2.default
            };

if (insertAtFront) {
                q._tasks.unshift(item);
            } else {
                q._tasks.push(item);
            }
        }

if (!processingScheduled) {
            processingScheduled = true;
            (0, _setImmediate2.default)(function () {
                processingScheduled = false;
                q.process();
            });
        }
    }

function _next(tasks) {
        return function (err) {
            numRunning -= 1;

for (var i = 0, l = tasks.length; i < l; i++) {
                var task = tasks[i];

var index = (0, _baseIndexOf2.default)(workersList, task, 0);
                if (index === 0) {
                    workersList.shift();
                } else if (index > 0) {
                    workersList.splice(index, 1);
                }

task.callback.apply(task, arguments);

if (err != null) {
                    q.error(err, task.data);
                }
            }

if (numRunning <= q.concurrency - q.buffer) {
                q.unsaturated();
            }

if (q.idle()) {
                q.drain();
            }
            q.process();
        };
    }

numRunning += 1;

if (q._tasks.length === 0) {
                    q.empty();
                }

if (numRunning === q.concurrency) {
                    q.saturated();
                }