diff options
Diffstat (limited to 'build/internal')
| -rw-r--r-- | build/internal/applyEach.js | 30 | ||||
| -rw-r--r-- | build/internal/concat.js | 18 | ||||
| -rw-r--r-- | build/internal/consoleFunc.js | 35 | ||||
| -rw-r--r-- | build/internal/createTester.js | 42 | ||||
| -rw-r--r-- | build/internal/doParallel.js | 19 | ||||
| -rw-r--r-- | build/internal/doParallelLimit.js | 19 | ||||
| -rw-r--r-- | build/internal/doSeries.js | 19 | ||||
| -rw-r--r-- | build/internal/eachOfLimit.js | 66 | ||||
| -rw-r--r-- | build/internal/filter.js | 41 | ||||
| -rw-r--r-- | build/internal/findGetResult.js | 10 | ||||
| -rw-r--r-- | build/internal/keyIterator.js | 36 | ||||
| -rw-r--r-- | build/internal/map.js | 35 | ||||
| -rw-r--r-- | build/internal/notId.js | 10 | ||||
| -rw-r--r-- | build/internal/onlyOnce.js | 14 | ||||
| -rw-r--r-- | build/internal/parallel.js | 38 | ||||
| -rw-r--r-- | build/internal/queue.js | 166 | ||||
| -rw-r--r-- | build/internal/reject.js | 25 | ||||
| -rw-r--r-- | build/internal/setImmediate.js | 23 | ||||
| -rw-r--r-- | build/internal/withoutIndex.js | 12 |
19 files changed, 0 insertions, 658 deletions
diff --git a/build/internal/applyEach.js b/build/internal/applyEach.js deleted file mode 100644 index a2534e0..0000000 --- a/build/internal/applyEach.js +++ /dev/null @@ -1,30 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = applyEach; - -var _rest = require('lodash/rest'); - -var _rest2 = _interopRequireDefault(_rest); - -function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } - -function applyEach(eachfn) { - return (0, _rest2.default)(function (fns, args) { - var go = (0, _rest2.default)(function (args) { - var that = this; - var callback = args.pop(); - return eachfn(fns, function (fn, _, cb) { - fn.apply(that, args.concat([cb])); - }, callback); - }); - if (args.length) { - return go.apply(this, args); - } else { - return go; - } - }); -} -module.exports = exports['default'];
\ No newline at end of file diff --git a/build/internal/concat.js b/build/internal/concat.js deleted file mode 100644 index 4fd7b26..0000000 --- a/build/internal/concat.js +++ /dev/null @@ -1,18 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = concat; -function concat(eachfn, arr, fn, callback) { - var result = []; - eachfn(arr, function (x, index, cb) { - fn(x, function (err, y) { - result = result.concat(y || []); - cb(err); - }); - }, function (err) { - callback(err, result); - }); -} -module.exports = exports['default'];
\ No newline at end of file diff --git a/build/internal/consoleFunc.js b/build/internal/consoleFunc.js deleted file mode 100644 index f7befa8..0000000 --- a/build/internal/consoleFunc.js +++ /dev/null @@ -1,35 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = consoleFunc; - -var _arrayEach = require('lodash/_arrayEach'); - -var _arrayEach2 = _interopRequireDefault(_arrayEach); - -var _rest = require('lodash/rest'); - -var _rest2 = _interopRequireDefault(_rest); - -function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } - -function consoleFunc(name) { - return (0, _rest2.default)(function (fn, args) { - fn.apply(null, args.concat([(0, _rest2.default)(function (err, args) { - if (typeof console === 'object') { - if (err) { - if (console.error) { - console.error(err); - } - } else if (console[name]) { - (0, _arrayEach2.default)(args, function (x) { - console[name](x); - }); - } - } - })])); - }); -} -module.exports = exports['default'];
\ No newline at end of file diff --git a/build/internal/createTester.js b/build/internal/createTester.js deleted file mode 100644 index 1f225a9..0000000 --- a/build/internal/createTester.js +++ /dev/null @@ -1,42 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = _createTester; -function _createTester(eachfn, check, getResult) { - return function (arr, limit, iterator, cb) { - function done(err) { - if (cb) { - if (err) { - cb(err); - } else { - cb(null, getResult(false, void 0)); - } - } - } - function iteratee(x, _, callback) { - if (!cb) return callback(); - iterator(x, function (err, v) { - if (cb) { - if (err) { - cb(err); - cb = iterator = false; - } else if (check(v)) { - cb(null, getResult(true, x)); - cb = iterator = false; - } - } - callback(); - }); - } - if (arguments.length > 3) { - eachfn(arr, limit, iteratee, done); - } else { - cb = iterator; - iterator = limit; - eachfn(arr, iteratee, done); - } - }; -} -module.exports = exports['default'];
\ No newline at end of file diff --git a/build/internal/doParallel.js b/build/internal/doParallel.js deleted file mode 100644 index a96a142..0000000 --- a/build/internal/doParallel.js +++ /dev/null @@ -1,19 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = doParallel; - -var _eachOf = require('../eachOf'); - -var _eachOf2 = _interopRequireDefault(_eachOf); - -function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } - -function doParallel(fn) { - return function (obj, iterator, callback) { - return fn(_eachOf2.default, obj, iterator, callback); - }; -} -module.exports = exports['default'];
\ No newline at end of file diff --git a/build/internal/doParallelLimit.js b/build/internal/doParallelLimit.js deleted file mode 100644 index 9472fd0..0000000 --- a/build/internal/doParallelLimit.js +++ /dev/null @@ -1,19 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = doParallelLimit; - -var _eachOfLimit = require('./eachOfLimit'); - -var _eachOfLimit2 = _interopRequireDefault(_eachOfLimit); - -function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } - -function doParallelLimit(fn) { - return function (obj, limit, iterator, callback) { - return fn((0, _eachOfLimit2.default)(limit), obj, iterator, callback); - }; -} -module.exports = exports['default'];
\ No newline at end of file diff --git a/build/internal/doSeries.js b/build/internal/doSeries.js deleted file mode 100644 index f17cd0d..0000000 --- a/build/internal/doSeries.js +++ /dev/null @@ -1,19 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = doSeries; - -var _eachOfSeries = require('../eachOfSeries'); - -var _eachOfSeries2 = _interopRequireDefault(_eachOfSeries); - -function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } - -function doSeries(fn) { - return function (obj, iterator, callback) { - return fn(_eachOfSeries2.default, obj, iterator, callback); - }; -} -module.exports = exports['default'];
\ No newline at end of file diff --git a/build/internal/eachOfLimit.js b/build/internal/eachOfLimit.js deleted file mode 100644 index 314b224..0000000 --- a/build/internal/eachOfLimit.js +++ /dev/null @@ -1,66 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = _eachOfLimit; - -var _noop = require('lodash/noop'); - -var _noop2 = _interopRequireDefault(_noop); - -var _once = require('lodash/once'); - -var _once2 = _interopRequireDefault(_once); - -var _keyIterator = require('./keyIterator'); - -var _keyIterator2 = _interopRequireDefault(_keyIterator); - -var _onlyOnce = require('./onlyOnce'); - -var _onlyOnce2 = _interopRequireDefault(_onlyOnce); - -function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } - -function _eachOfLimit(limit) { - return function (obj, iterator, callback) { - callback = (0, _once2.default)(callback || _noop2.default); - obj = obj || []; - var nextKey = (0, _keyIterator2.default)(obj); - if (limit <= 0) { - return callback(null); - } - var done = false; - var running = 0; - var errored = false; - - (function replenish() { - if (done && running <= 0) { - return callback(null); - } - - while (running < limit && !errored) { - var key = nextKey(); - if (key === null) { - done = true; - if (running <= 0) { - callback(null); - } - return; - } - running += 1; - iterator(obj[key], key, (0, _onlyOnce2.default)(function (err) { - running -= 1; - if (err) { - callback(err); - errored = true; - } else { - replenish(); - } - })); - } - })(); - }; -} -module.exports = exports['default'];
\ No newline at end of file diff --git a/build/internal/filter.js b/build/internal/filter.js deleted file mode 100644 index 1b8a911..0000000 --- a/build/internal/filter.js +++ /dev/null @@ -1,41 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = _filter; - -var _arrayMap = require('lodash/_arrayMap'); - -var _arrayMap2 = _interopRequireDefault(_arrayMap); - -var _baseProperty = require('lodash/_baseProperty'); - -var _baseProperty2 = _interopRequireDefault(_baseProperty); - -function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } - -function _filter(eachfn, arr, iterator, callback) { - var results = []; - eachfn(arr, function (x, index, callback) { - iterator(x, function (err, v) { - if (err) { - callback(err); - } else { - if (v) { - results.push({ index: index, value: x }); - } - callback(); - } - }); - }, function (err) { - if (err) { - callback(err); - } else { - callback(null, (0, _arrayMap2.default)(results.sort(function (a, b) { - return a.index - b.index; - }), (0, _baseProperty2.default)('value'))); - } - }); -} -module.exports = exports['default'];
\ No newline at end of file diff --git a/build/internal/findGetResult.js b/build/internal/findGetResult.js deleted file mode 100644 index 46d0140..0000000 --- a/build/internal/findGetResult.js +++ /dev/null @@ -1,10 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = _findGetResult; -function _findGetResult(v, x) { - return x; -} -module.exports = exports['default'];
\ No newline at end of file diff --git a/build/internal/keyIterator.js b/build/internal/keyIterator.js deleted file mode 100644 index 3ed3ab1..0000000 --- a/build/internal/keyIterator.js +++ /dev/null @@ -1,36 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = keyIterator; - -var _isArrayLike = require('lodash/isArrayLike'); - -var _isArrayLike2 = _interopRequireDefault(_isArrayLike); - -var _keys = require('lodash/keys'); - -var _keys2 = _interopRequireDefault(_keys); - -function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } - -function keyIterator(coll) { - var i = -1; - var len; - if ((0, _isArrayLike2.default)(coll)) { - len = coll.length; - return function next() { - i++; - return i < len ? i : null; - }; - } else { - var okeys = (0, _keys2.default)(coll); - len = okeys.length; - return function next() { - i++; - return i < len ? okeys[i] : null; - }; - } -} -module.exports = exports['default'];
\ No newline at end of file diff --git a/build/internal/map.js b/build/internal/map.js deleted file mode 100644 index ac47206..0000000 --- a/build/internal/map.js +++ /dev/null @@ -1,35 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = _asyncMap; - -var _isArrayLike = require('lodash/isArrayLike'); - -var _isArrayLike2 = _interopRequireDefault(_isArrayLike); - -var _noop = require('lodash/noop'); - -var _noop2 = _interopRequireDefault(_noop); - -var _once = require('lodash/once'); - -var _once2 = _interopRequireDefault(_once); - -function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } - -function _asyncMap(eachfn, arr, iterator, callback) { - callback = (0, _once2.default)(callback || _noop2.default); - arr = arr || []; - var results = (0, _isArrayLike2.default)(arr) ? [] : {}; - eachfn(arr, function (value, index, callback) { - iterator(value, function (err, v) { - results[index] = v; - callback(err); - }); - }, function (err) { - callback(err, results); - }); -} -module.exports = exports['default'];
\ No newline at end of file diff --git a/build/internal/notId.js b/build/internal/notId.js deleted file mode 100644 index 432ab12..0000000 --- a/build/internal/notId.js +++ /dev/null @@ -1,10 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = notId; -function notId(v) { - return !v; -} -module.exports = exports['default'];
\ No newline at end of file diff --git a/build/internal/onlyOnce.js b/build/internal/onlyOnce.js deleted file mode 100644 index 25e6779..0000000 --- a/build/internal/onlyOnce.js +++ /dev/null @@ -1,14 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = onlyOnce; -function onlyOnce(fn) { - return function () { - if (fn === null) throw new Error("Callback was already called."); - fn.apply(this, arguments); - fn = null; - }; -} -module.exports = exports['default'];
\ No newline at end of file diff --git a/build/internal/parallel.js b/build/internal/parallel.js deleted file mode 100644 index f04888c..0000000 --- a/build/internal/parallel.js +++ /dev/null @@ -1,38 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = _parallel; - -var _noop = require('lodash/noop'); - -var _noop2 = _interopRequireDefault(_noop); - -var _isArrayLike = require('lodash/isArrayLike'); - -var _isArrayLike2 = _interopRequireDefault(_isArrayLike); - -var _rest = require('lodash/rest'); - -var _rest2 = _interopRequireDefault(_rest); - -function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } - -function _parallel(eachfn, tasks, callback) { - callback = callback || _noop2.default; - var results = (0, _isArrayLike2.default)(tasks) ? [] : {}; - - eachfn(tasks, function (task, key, callback) { - task((0, _rest2.default)(function (err, args) { - if (args.length <= 1) { - args = args[0]; - } - results[key] = args; - callback(err); - })); - }, function (err) { - callback(err, results); - }); -} -module.exports = exports['default'];
\ No newline at end of file diff --git a/build/internal/queue.js b/build/internal/queue.js deleted file mode 100644 index 72fc685..0000000 --- a/build/internal/queue.js +++ /dev/null @@ -1,166 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = queue; - -var _arrayEach = require('lodash/_arrayEach'); - -var _arrayEach2 = _interopRequireDefault(_arrayEach); - -var _arrayMap = require('lodash/_arrayMap'); - -var _arrayMap2 = _interopRequireDefault(_arrayMap); - -var _isArray = require('lodash/isArray'); - -var _isArray2 = _interopRequireDefault(_isArray); - -var _noop = require('lodash/noop'); - -var _noop2 = _interopRequireDefault(_noop); - -var _baseProperty = require('lodash/_baseProperty'); - -var _baseProperty2 = _interopRequireDefault(_baseProperty); - -var _onlyOnce = require('./onlyOnce'); - -var _onlyOnce2 = _interopRequireDefault(_onlyOnce); - -var _setImmediate = require('./setImmediate'); - -var _setImmediate2 = _interopRequireDefault(_setImmediate); - -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'); - } - function _insert(q, data, pos, callback) { - if (callback != null && typeof callback !== 'function') { - throw new Error('task callback must be a function'); - } - q.started = true; - if (!(0, _isArray2.default)(data)) { - data = [data]; - } - if (data.length === 0 && q.idle()) { - // call drain immediately if there are no tasks - return (0, _setImmediate2.default)(function () { - q.drain(); - }); - } - (0, _arrayEach2.default)(data, function (task) { - var item = { - data: task, - callback: callback || _noop2.default - }; - - if (pos) { - q.tasks.unshift(item); - } else { - q.tasks.push(item); - } - - if (q.tasks.length === q.concurrency) { - q.saturated(); - } - }); - (0, _setImmediate2.default)(q.process); - } - function _next(q, tasks) { - return function () { - workers -= 1; - - var removed = false; - var args = arguments; - (0, _arrayEach2.default)(tasks, function (task) { - (0, _arrayEach2.default)(workersList, function (worker, index) { - if (worker === task && !removed) { - workersList.splice(index, 1); - removed = true; - } - }); - - task.callback.apply(task, args); - }); - if (q.tasks.length + workers === 0) { - q.drain(); - } - q.process(); - }; - } - - var workers = 0; - var workersList = []; - var q = { - tasks: [], - concurrency: concurrency, - payload: payload, - saturated: _noop2.default, - empty: _noop2.default, - drain: _noop2.default, - started: false, - paused: false, - push: function (data, callback) { - _insert(q, data, false, callback); - }, - kill: function () { - q.drain = _noop2.default; - q.tasks = []; - }, - unshift: function (data, callback) { - _insert(q, data, true, callback); - }, - process: function () { - while (!q.paused && workers < q.concurrency && q.tasks.length) { - - var tasks = q.payload ? q.tasks.splice(0, q.payload) : q.tasks.splice(0, q.tasks.length); - - var data = (0, _arrayMap2.default)(tasks, (0, _baseProperty2.default)('data')); - - if (q.tasks.length === 0) { - q.empty(); - } - workers += 1; - workersList.push(tasks[0]); - var cb = (0, _onlyOnce2.default)(_next(q, tasks)); - worker(data, cb); - } - }, - length: function () { - return q.tasks.length; - }, - running: function () { - return workers; - }, - workersList: function () { - return workersList; - }, - idle: function () { - return q.tasks.length + workers === 0; - }, - pause: function () { - q.paused = true; - }, - resume: function () { - if (q.paused === false) { - return; - } - q.paused = false; - var resumeCount = Math.min(q.concurrency, q.tasks.length); - // Need to call q.process once per concurrent - // worker to preserve full concurrency after pause - for (var w = 1; w <= resumeCount; w++) { - (0, _setImmediate2.default)(q.process); - } - } - }; - return q; -} -module.exports = exports['default'];
\ No newline at end of file diff --git a/build/internal/reject.js b/build/internal/reject.js deleted file mode 100644 index 1aba930..0000000 --- a/build/internal/reject.js +++ /dev/null @@ -1,25 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = reject; - -var _filter = require('./filter'); - -var _filter2 = _interopRequireDefault(_filter); - -function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } - -function reject(eachfn, arr, iterator, callback) { - (0, _filter2.default)(eachfn, arr, function (value, cb) { - iterator(value, function (err, v) { - if (err) { - cb(err); - } else { - cb(null, !v); - } - }); - }, callback); -} -module.exports = exports['default'];
\ No newline at end of file diff --git a/build/internal/setImmediate.js b/build/internal/setImmediate.js deleted file mode 100644 index 8157f22..0000000 --- a/build/internal/setImmediate.js +++ /dev/null @@ -1,23 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -var _setImmediate = typeof setImmediate === 'function' && setImmediate; - -var _delay; -if (_setImmediate) { - _delay = function (fn) { - // not a direct alias for IE10 compatibility - _setImmediate(fn); - }; -} else if (typeof process === 'object' && typeof process.nextTick === 'function') { - _delay = process.nextTick; -} else { - _delay = function (fn) { - setTimeout(fn, 0); - }; -} - -exports.default = _delay; -module.exports = exports['default'];
\ No newline at end of file diff --git a/build/internal/withoutIndex.js b/build/internal/withoutIndex.js deleted file mode 100644 index 7bc3771..0000000 --- a/build/internal/withoutIndex.js +++ /dev/null @@ -1,12 +0,0 @@ -'use strict'; - -Object.defineProperty(exports, "__esModule", { - value: true -}); -exports.default = _withoutIndex; -function _withoutIndex(iterator) { - return function (value, index, callback) { - return iterator(value, callback); - }; -} -module.exports = exports['default'];
\ No newline at end of file |