summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorFederico Brigante <github@bfred.it>2018-04-19 17:41:21 +0700
committerFederico Brigante <github@bfred.it>2018-04-19 18:33:23 +0700
commitdbed9147efc5b48db5e58b274f6b5e4a718c85c3 (patch)
treeb153e527332dc84aabeaacd5e0fed93ececef38c
parent94f2b17be05a2f00a0562e91f77e4eb214da61b4 (diff)
downloadasync-dbed9147efc5b48db5e58b274f6b5e4a718c85c3.tar.gz
Drop isArray
-rw-r--r--lib/auto.js5
-rw-r--r--lib/autoInject.js3
-rw-r--r--lib/internal/queue.js3
-rw-r--r--lib/priorityQueue.js3
-rw-r--r--lib/race.js3
-rw-r--r--lib/reflectAll.js3
-rw-r--r--lib/transform.js3
-rw-r--r--lib/waterfall.js3
8 files changed, 9 insertions, 17 deletions
diff --git a/lib/auto.js b/lib/auto.js
index 2a6f5c4..8dbc56c 100644
--- a/lib/auto.js
+++ b/lib/auto.js
@@ -1,5 +1,4 @@
import indexOf from 'lodash/_baseIndexOf';
-import isArray from 'lodash/isArray';
import okeys from 'lodash/keys';
import noop from 'lodash/noop';
@@ -118,7 +117,7 @@ export default function (tasks, concurrency, callback) {
var uncheckedDependencies = {};
forOwn(tasks, function (task, key) {
- if (!isArray(task)) {
+ if (!Array.isArray(task)) {
// no dependencies
enqueueTask(key, [task]);
readyToCheck.push(key);
@@ -247,7 +246,7 @@ export default function (tasks, concurrency, callback) {
function getDependents(taskName) {
var result = [];
forOwn(tasks, function (task, key) {
- if (isArray(task) && indexOf(task, taskName, 0) >= 0) {
+ if (Array.isArray(task) && indexOf(task, taskName, 0) >= 0) {
result.push(key);
}
});
diff --git a/lib/autoInject.js b/lib/autoInject.js
index 70ffa53..0989284 100644
--- a/lib/autoInject.js
+++ b/lib/autoInject.js
@@ -1,6 +1,5 @@
import auto from './auto';
import arrayMap from 'lodash/_arrayMap';
-import isArray from 'lodash/isArray';
import trim from 'lodash/trim';
import forOwn from './internal/forOwn';
import wrapAsync from './internal/wrapAsync';
@@ -113,7 +112,7 @@ export default function autoInject(tasks, callback) {
(!fnIsAsync && taskFn.length === 1) ||
(fnIsAsync && taskFn.length === 0);
- if (isArray(taskFn)) {
+ if (Array.isArray(taskFn)) {
params = taskFn.slice(0, -1);
taskFn = taskFn[taskFn.length - 1];
diff --git a/lib/internal/queue.js b/lib/internal/queue.js
index 1a3f4cb..bc9a790 100644
--- a/lib/internal/queue.js
+++ b/lib/internal/queue.js
@@ -1,5 +1,4 @@
import indexOf from 'lodash/_baseIndexOf';
-import isArray from 'lodash/isArray';
import noop from 'lodash/noop';
import onlyOnce from './onlyOnce';
@@ -25,7 +24,7 @@ export default function queue(worker, concurrency, payload) {
throw new Error('task callback must be a function');
}
q.started = true;
- if (!isArray(data)) {
+ if (!Array.isArray(data)) {
data = [data];
}
if (data.length === 0 && q.idle()) {
diff --git a/lib/priorityQueue.js b/lib/priorityQueue.js
index aff7293..b190bdf 100644
--- a/lib/priorityQueue.js
+++ b/lib/priorityQueue.js
@@ -1,4 +1,3 @@
-import isArray from 'lodash/isArray';
import noop from 'lodash/noop';
import setImmediate from './setImmediate';
@@ -39,7 +38,7 @@ export default function(worker, concurrency) {
throw new Error('task callback must be a function');
}
q.started = true;
- if (!isArray(data)) {
+ if (!Array.isArray(data)) {
data = [data];
}
if (data.length === 0) {
diff --git a/lib/race.js b/lib/race.js
index 9b4d6c3..48e8fdc 100644
--- a/lib/race.js
+++ b/lib/race.js
@@ -1,4 +1,3 @@
-import isArray from 'lodash/isArray';
import noop from 'lodash/noop';
import once from './internal/once';
import wrapAsync from './internal/wrapAsync';
@@ -41,7 +40,7 @@ import wrapAsync from './internal/wrapAsync';
*/
export default function race(tasks, callback) {
callback = once(callback || noop);
- if (!isArray(tasks)) return callback(new TypeError('First argument to race must be an array of functions'));
+ if (!Array.isArray(tasks)) return callback(new TypeError('First argument to race must be an array of functions'));
if (!tasks.length) return callback();
for (var i = 0, l = tasks.length; i < l; i++) {
wrapAsync(tasks[i])(callback);
diff --git a/lib/reflectAll.js b/lib/reflectAll.js
index 96ec73b..8e4b3c3 100644
--- a/lib/reflectAll.js
+++ b/lib/reflectAll.js
@@ -1,5 +1,4 @@
import reflect from './reflect';
-import isArray from 'lodash/isArray';
import _arrayMap from 'lodash/_arrayMap';
import forOwn from './internal/forOwn';
@@ -72,7 +71,7 @@ import forOwn from './internal/forOwn';
*/
export default function reflectAll(tasks) {
var results;
- if (isArray(tasks)) {
+ if (Array.isArray(tasks)) {
results = _arrayMap(tasks, reflect);
} else {
results = {};
diff --git a/lib/transform.js b/lib/transform.js
index ef254a1..ac2631f 100644
--- a/lib/transform.js
+++ b/lib/transform.js
@@ -1,4 +1,3 @@
-import isArray from 'lodash/isArray';
import noop from 'lodash/noop';
import eachOf from './eachOf';
@@ -51,7 +50,7 @@ export default function transform (coll, accumulator, iteratee, callback) {
if (arguments.length <= 3) {
callback = iteratee;
iteratee = accumulator;
- accumulator = isArray(coll) ? [] : {};
+ accumulator = Array.isArray(coll) ? [] : {};
}
callback = once(callback || noop);
var _iteratee = wrapAsync(iteratee);
diff --git a/lib/waterfall.js b/lib/waterfall.js
index 092f3ac..b666de3 100644
--- a/lib/waterfall.js
+++ b/lib/waterfall.js
@@ -1,4 +1,3 @@
-import isArray from 'lodash/isArray';
import noop from 'lodash/noop';
import once from './internal/once';
import slice from './internal/slice';
@@ -65,7 +64,7 @@ import wrapAsync from './internal/wrapAsync';
*/
export default function(tasks, callback) {
callback = once(callback || noop);
- if (!isArray(tasks)) return callback(new Error('First argument to waterfall must be an array of functions'));
+ if (!Array.isArray(tasks)) return callback(new Error('First argument to waterfall must be an array of functions'));
if (!tasks.length) return callback();
var taskIndex = 0;