diff options
author | Federico Brigante <github@bfred.it> | 2018-04-19 17:41:21 +0700 |
---|---|---|
committer | Federico Brigante <github@bfred.it> | 2018-04-19 18:33:23 +0700 |
commit | dbed9147efc5b48db5e58b274f6b5e4a718c85c3 (patch) | |
tree | b153e527332dc84aabeaacd5e0fed93ececef38c | |
parent | 94f2b17be05a2f00a0562e91f77e4eb214da61b4 (diff) | |
download | async-dbed9147efc5b48db5e58b274f6b5e4a718c85c3.tar.gz |
Drop isArray
-rw-r--r-- | lib/auto.js | 5 | ||||
-rw-r--r-- | lib/autoInject.js | 3 | ||||
-rw-r--r-- | lib/internal/queue.js | 3 | ||||
-rw-r--r-- | lib/priorityQueue.js | 3 | ||||
-rw-r--r-- | lib/race.js | 3 | ||||
-rw-r--r-- | lib/reflectAll.js | 3 | ||||
-rw-r--r-- | lib/transform.js | 3 | ||||
-rw-r--r-- | lib/waterfall.js | 3 |
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; |