summaryrefslogtreecommitdiff
path: root/build-es/internal
diff options
context:
space:
mode:
Diffstat (limited to 'build-es/internal')
-rw-r--r--build-es/internal/applyEach.js22
-rw-r--r--build-es/internal/concat.js13
-rw-r--r--build-es/internal/consoleFunc.js23
-rw-r--r--build-es/internal/createTester.js37
-rw-r--r--build-es/internal/doParallel.js9
-rw-r--r--build-es/internal/doParallelLimit.js9
-rw-r--r--build-es/internal/doSeries.js9
-rw-r--r--build-es/internal/eachOfLimit.js49
-rw-r--r--build-es/internal/filter.js30
-rw-r--r--build-es/internal/findGetResult.js5
-rw-r--r--build-es/internal/keyIterator.js23
-rw-r--r--build-es/internal/map.js19
-rw-r--r--build-es/internal/notId.js5
-rw-r--r--build-es/internal/onlyOnce.js9
-rw-r--r--build-es/internal/parallel.js22
-rw-r--r--build-es/internal/queue.js140
-rw-r--r--build-es/internal/reject.js15
-rw-r--r--build-es/internal/setImmediate.js19
-rw-r--r--build-es/internal/withoutIndex.js7
19 files changed, 0 insertions, 465 deletions
diff --git a/build-es/internal/applyEach.js b/build-es/internal/applyEach.js
deleted file mode 100644
index 1467363..0000000
--- a/build-es/internal/applyEach.js
+++ /dev/null
@@ -1,22 +0,0 @@
-'use strict';
-
-import rest from 'lodash-es/rest';
-
-export default function applyEach(eachfn) {
- return rest(function(fns, args) {
- var go = rest(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;
- }
- });
-}
diff --git a/build-es/internal/concat.js b/build-es/internal/concat.js
deleted file mode 100644
index 482ad3a..0000000
--- a/build-es/internal/concat.js
+++ /dev/null
@@ -1,13 +0,0 @@
-'use strict';
-
-export default 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);
- });
-}
diff --git a/build-es/internal/consoleFunc.js b/build-es/internal/consoleFunc.js
deleted file mode 100644
index d56a7bd..0000000
--- a/build-es/internal/consoleFunc.js
+++ /dev/null
@@ -1,23 +0,0 @@
-'use strict';
-
-import arrayEach from 'lodash-es/_arrayEach';
-import rest from 'lodash-es/rest';
-
-export default function consoleFunc(name) {
- return rest(function (fn, args) {
- fn.apply(null, args.concat([rest(function (err, args) {
- if (typeof console === 'object') {
- if (err) {
- if (console.error) {
- console.error(err);
- }
- }
- else if (console[name]) {
- arrayEach(args, function (x) {
- console[name](x);
- });
- }
- }
- })]));
- });
-}
diff --git a/build-es/internal/createTester.js b/build-es/internal/createTester.js
deleted file mode 100644
index 0e9e750..0000000
--- a/build-es/internal/createTester.js
+++ /dev/null
@@ -1,37 +0,0 @@
-'use strict';
-
-export default 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);
- }
- };
-}
diff --git a/build-es/internal/doParallel.js b/build-es/internal/doParallel.js
deleted file mode 100644
index 19c90fc..0000000
--- a/build-es/internal/doParallel.js
+++ /dev/null
@@ -1,9 +0,0 @@
-'use strict';
-
-import eachOf from '../eachOf';
-
-export default function doParallel(fn) {
- return function (obj, iterator, callback) {
- return fn(eachOf, obj, iterator, callback);
- };
-}
diff --git a/build-es/internal/doParallelLimit.js b/build-es/internal/doParallelLimit.js
deleted file mode 100644
index 0c3bcf7..0000000
--- a/build-es/internal/doParallelLimit.js
+++ /dev/null
@@ -1,9 +0,0 @@
-'use strict';
-
-import eachOfLimit from './eachOfLimit';
-
-export default function doParallelLimit(fn) {
- return function (obj, limit, iterator, callback) {
- return fn(eachOfLimit(limit), obj, iterator, callback);
- };
-}
diff --git a/build-es/internal/doSeries.js b/build-es/internal/doSeries.js
deleted file mode 100644
index c7f1d99..0000000
--- a/build-es/internal/doSeries.js
+++ /dev/null
@@ -1,9 +0,0 @@
-'use strict';
-
-import eachOfSeries from '../eachOfSeries';
-
-export default function doSeries(fn) {
- return function (obj, iterator, callback) {
- return fn(eachOfSeries, obj, iterator, callback);
- };
-}
diff --git a/build-es/internal/eachOfLimit.js b/build-es/internal/eachOfLimit.js
deleted file mode 100644
index 5235278..0000000
--- a/build-es/internal/eachOfLimit.js
+++ /dev/null
@@ -1,49 +0,0 @@
-'use strict';
-
-import noop from 'lodash-es/noop';
-import once from 'lodash-es/once';
-
-import keyIterator from './keyIterator';
-import onlyOnce from './onlyOnce';
-
-export default function _eachOfLimit(limit) {
- return function (obj, iterator, callback) {
- callback = once(callback || noop);
- obj = obj || [];
- var nextKey = keyIterator(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, onlyOnce(function (err) {
- running -= 1;
- if (err) {
- callback(err);
- errored = true;
- }
- else {
- replenish();
- }
- }));
- }
- })();
- };
-}
diff --git a/build-es/internal/filter.js b/build-es/internal/filter.js
deleted file mode 100644
index d1ab3e3..0000000
--- a/build-es/internal/filter.js
+++ /dev/null
@@ -1,30 +0,0 @@
-'use strict';
-
-import arrayMap from 'lodash-es/_arrayMap';
-import property from 'lodash-es/_baseProperty';
-
-export default 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, arrayMap(results.sort(function (a, b) {
- return a.index - b.index;
- }), property('value')));
- }
- });
-}
diff --git a/build-es/internal/findGetResult.js b/build-es/internal/findGetResult.js
deleted file mode 100644
index 3aeb07d..0000000
--- a/build-es/internal/findGetResult.js
+++ /dev/null
@@ -1,5 +0,0 @@
-'use strict';
-
-export default function _findGetResult(v, x) {
- return x;
-}
diff --git a/build-es/internal/keyIterator.js b/build-es/internal/keyIterator.js
deleted file mode 100644
index 9f12beb..0000000
--- a/build-es/internal/keyIterator.js
+++ /dev/null
@@ -1,23 +0,0 @@
-'use strict';
-
-import isArrayLike from 'lodash-es/isArrayLike';
-import keys from 'lodash-es/keys';
-
-export default function keyIterator(coll) {
- var i = -1;
- var len;
- if (isArrayLike(coll)) {
- len = coll.length;
- return function next() {
- i++;
- return i < len ? i : null;
- };
- } else {
- var okeys = keys(coll);
- len = okeys.length;
- return function next() {
- i++;
- return i < len ? okeys[i] : null;
- };
- }
-}
diff --git a/build-es/internal/map.js b/build-es/internal/map.js
deleted file mode 100644
index 5057f49..0000000
--- a/build-es/internal/map.js
+++ /dev/null
@@ -1,19 +0,0 @@
-'use strict';
-
-import isArrayLike from 'lodash-es/isArrayLike';
-import noop from 'lodash-es/noop';
-import once from 'lodash-es/once';
-
-export default function _asyncMap(eachfn, arr, iterator, callback) {
- callback = once(callback || noop);
- arr = arr || [];
- var results = isArrayLike(arr) ? [] : {};
- eachfn(arr, function (value, index, callback) {
- iterator(value, function (err, v) {
- results[index] = v;
- callback(err);
- });
- }, function (err) {
- callback(err, results);
- });
-}
diff --git a/build-es/internal/notId.js b/build-es/internal/notId.js
deleted file mode 100644
index d936aab..0000000
--- a/build-es/internal/notId.js
+++ /dev/null
@@ -1,5 +0,0 @@
-'use strict';
-
-export default function notId(v) {
- return !v;
-}
diff --git a/build-es/internal/onlyOnce.js b/build-es/internal/onlyOnce.js
deleted file mode 100644
index f4241c8..0000000
--- a/build-es/internal/onlyOnce.js
+++ /dev/null
@@ -1,9 +0,0 @@
-'use strict';
-
-export default function onlyOnce(fn) {
- return function() {
- if (fn === null) throw new Error("Callback was already called.");
- fn.apply(this, arguments);
- fn = null;
- };
-}
diff --git a/build-es/internal/parallel.js b/build-es/internal/parallel.js
deleted file mode 100644
index b532908..0000000
--- a/build-es/internal/parallel.js
+++ /dev/null
@@ -1,22 +0,0 @@
-'use strict';
-
-import noop from 'lodash-es/noop';
-import isArrayLike from 'lodash-es/isArrayLike';
-import rest from 'lodash-es/rest';
-
-export default function _parallel(eachfn, tasks, callback) {
- callback = callback || noop;
- var results = isArrayLike(tasks) ? [] : {};
-
- eachfn(tasks, function (task, key, callback) {
- task(rest(function (err, args) {
- if (args.length <= 1) {
- args = args[0];
- }
- results[key] = args;
- callback(err);
- }));
- }, function (err) {
- callback(err, results);
- });
-}
diff --git a/build-es/internal/queue.js b/build-es/internal/queue.js
deleted file mode 100644
index e15229b..0000000
--- a/build-es/internal/queue.js
+++ /dev/null
@@ -1,140 +0,0 @@
-'use strict';
-
-import arrayEach from 'lodash-es/_arrayEach';
-import arrayMap from 'lodash-es/_arrayMap';
-import isArray from 'lodash-es/isArray';
-import noop from 'lodash-es/noop';
-import property from 'lodash-es/_baseProperty';
-
-import onlyOnce from './onlyOnce';
-import setImmediate from './setImmediate';
-
-export default 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 (!isArray(data)) {
- data = [data];
- }
- if(data.length === 0 && q.idle()) {
- // call drain immediately if there are no tasks
- return setImmediate(function() {
- q.drain();
- });
- }
- arrayEach(data, function(task) {
- var item = {
- data: task,
- callback: callback || noop
- };
-
- if (pos) {
- q.tasks.unshift(item);
- } else {
- q.tasks.push(item);
- }
-
- if (q.tasks.length === q.concurrency) {
- q.saturated();
- }
- });
- setImmediate(q.process);
- }
- function _next(q, tasks) {
- return function(){
- workers -= 1;
-
- var removed = false;
- var args = arguments;
- arrayEach(tasks, function (task) {
- arrayEach(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: noop,
- empty: noop,
- drain: noop,
- started: false,
- paused: false,
- push: function (data, callback) {
- _insert(q, data, false, callback);
- },
- kill: function () {
- q.drain = noop;
- 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 = arrayMap(tasks, property('data'));
-
- if (q.tasks.length === 0) {
- q.empty();
- }
- workers += 1;
- workersList.push(tasks[0]);
- var cb = onlyOnce(_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++) {
- setImmediate(q.process);
- }
- }
- };
- return q;
-}
diff --git a/build-es/internal/reject.js b/build-es/internal/reject.js
deleted file mode 100644
index 708e810..0000000
--- a/build-es/internal/reject.js
+++ /dev/null
@@ -1,15 +0,0 @@
-'use strict';
-
-import filter from './filter';
-
-export default function reject(eachfn, arr, iterator, callback) {
- filter(eachfn, arr, function(value, cb) {
- iterator(value, function(err, v) {
- if (err) {
- cb(err);
- } else {
- cb(null, !v);
- }
- });
- }, callback);
-}
diff --git a/build-es/internal/setImmediate.js b/build-es/internal/setImmediate.js
deleted file mode 100644
index c02ad71..0000000
--- a/build-es/internal/setImmediate.js
+++ /dev/null
@@ -1,19 +0,0 @@
-'use strict';
-
-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);
- };
-}
-
-export default _delay;
diff --git a/build-es/internal/withoutIndex.js b/build-es/internal/withoutIndex.js
deleted file mode 100644
index f163ff3..0000000
--- a/build-es/internal/withoutIndex.js
+++ /dev/null
@@ -1,7 +0,0 @@
-'use strict';
-
-export default function _withoutIndex(iterator) {
- return function (value, index, callback) {
- return iterator(value, callback);
- };
-}
View Lorry Controller Status