diff options
author | Alexander Early <alexander.early@gmail.com> | 2015-05-27 23:42:57 -0700 |
---|---|---|
committer | Alexander Early <alexander.early@gmail.com> | 2015-05-27 23:42:57 -0700 |
commit | d35f46067805248be4127030cedda0a80f80b938 (patch) | |
tree | db22d29c55417c43e6d8710ec31ead8f64aa44b8 | |
parent | 1b258fb79db17ea94e2f6af2372b85f9fef37258 (diff) | |
download | async-d35f46067805248be4127030cedda0a80f80b938.tar.gz |
code style changes
-rw-r--r-- | lib/async.js | 106 |
1 files changed, 53 insertions, 53 deletions
diff --git a/lib/async.js b/lib/async.js index b8c001b..1fc920c 100644 --- a/lib/async.js +++ b/lib/async.js @@ -8,7 +8,7 @@ (function () { var async = {}; - var noop = function () {}; + function noop() {} // global on the server, window in the browser var root, previous_async; @@ -49,16 +49,16 @@ return _toString.call(obj) === '[object Array]'; }; - var _each = function (arr, iterator) { + function _each(arr, iterator) { var index = -1, length = arr.length; while (++index < length) { iterator(arr[index], index, arr); } - }; + } - var _map = function (arr, iterator) { + function _map(arr, iterator) { var index = -1, length = arr.length, result = Array(length); @@ -67,20 +67,20 @@ result[index] = iterator(arr[index], index, arr); } return result; - }; + } - var _reduce = function (arr, iterator, memo) { + function _reduce(arr, iterator, memo) { _each(arr, function (x, i, a) { memo = iterator(memo, x, i, a); }); return memo; - }; + } - var _forEachOf = function (object, iterator) { + function _forEachOf(object, iterator) { _each(_keys(object), function (key) { iterator(object[key], key); }); - }; + } var _keys = Object.keys || function (obj) { var keys = []; @@ -92,7 +92,7 @@ return keys; }; - var _baseSlice = function (arr, start) { + function _baseSlice(arr, start) { start = start || 0; var index = -1; var length = arr.length; @@ -107,7 +107,7 @@ result[index] = arr[index + start]; } return result; - }; + } //// exported async module functions //// @@ -147,6 +147,7 @@ } } + async.forEach = async.each = function (arr, iterator, callback) { callback = callback || noop; if (!arr.length) { @@ -169,8 +170,8 @@ } } }; - async.forEach = async.each; + async.forEachSeries = async.eachSeries = function (arr, iterator, callback) { callback = callback || noop; if (!arr.length) { @@ -196,16 +197,15 @@ }; iterate(); }; - async.forEachSeries = async.eachSeries; + async.forEachLimit = async.eachLimit = function (arr, limit, iterator, callback) { var fn = _eachLimit(limit); fn.apply(null, [arr, iterator, callback]); }; - async.forEachLimit = async.eachLimit; - var _eachLimit = function (limit) { + function _eachLimit(limit) { return function (arr, iterator, callback) { callback = callback || noop; @@ -245,11 +245,12 @@ } })(); }; - }; + } - async.forEachOf = async.eachOf = function (object, iterator, callback) { + async.forEachOf = + async.eachOf = function (object, iterator, callback) { callback = callback || function () {}; var size = object.length || _keys(object).length; var completed = 0; @@ -271,7 +272,8 @@ }); }; - async.forEachOfSeries = async.eachOfSeries = function (obj, iterator, callback) { + async.forEachOfSeries = + async.eachOfSeries = function (obj, iterator, callback) { callback = callback || function () {}; var keys = _keys(obj); var size = keys.length; @@ -309,11 +311,12 @@ - async.forEachOfLimit = async.eachOfLimit = function (obj, limit, iterator, callback) { - _forEachOfLimit(limit)(obj, iterator, callback); + async.forEachOfLimit = + async.eachOfLimit = function (obj, limit, iterator, callback) { + _eachOfLimit(limit)(obj, iterator, callback); }; - var _forEachOfLimit = function (limit) { + function _eachOfLimit(limit) { return function (obj, iterator, callback) { callback = callback || function () {}; @@ -354,30 +357,30 @@ } })(); }; - }; + } - var doParallel = function (fn) { + function doParallel(fn) { return function () { var args = _baseSlice(arguments); return fn.apply(null, [async.each].concat(args)); }; - }; - var doParallelLimit = function(limit, fn) { + } + function doParallelLimit(limit, fn) { return function () { var args = _baseSlice(arguments); return fn.apply(null, [_eachLimit(limit)].concat(args)); }; - }; - var doSeries = function (fn) { + } + function doSeries(fn) { return function () { var args = _baseSlice(arguments); return fn.apply(null, [async.eachSeries].concat(args)); }; - }; + } - var _asyncMap = function (eachfn, arr, iterator, callback) { + function _asyncMap(eachfn, arr, iterator, callback) { arr = _map(arr, function (x, i) { return {index: i, value: x}; }); @@ -398,19 +401,22 @@ callback(err, results); }); } - }; + } + async.map = doParallel(_asyncMap); async.mapSeries = doSeries(_asyncMap); async.mapLimit = function (arr, limit, iterator, callback) { return _mapLimit(limit)(arr, iterator, callback); }; - var _mapLimit = function(limit) { + function _mapLimit(limit) { return doParallelLimit(limit, _asyncMap); - }; + } // reduce only has a series version, as doing reduce in parallel won't // work in many situations. + async.inject = + async.foldl = async.reduce = function (arr, memo, iterator, callback) { async.eachSeries(arr, function (x, callback) { iterator(memo, x, function (err, v) { @@ -421,21 +427,16 @@ callback(err || null, memo); }); }; - // inject alias - async.inject = async.reduce; - // foldl alias - async.foldl = async.reduce; + async.foldr = async.reduceRight = function (arr, memo, iterator, callback) { var reversed = _map(arr, function (x) { return x; }).reverse(); async.reduce(reversed, memo, iterator, callback); }; - // foldr alias - async.foldr = async.reduceRight; - var _filter = function (eachfn, arr, iterator, callback) { + function _filter(eachfn, arr, iterator, callback) { var results = []; arr = _map(arr, function (x, i) { return {index: i, value: x}; @@ -454,14 +455,15 @@ return x.value; })); }); - }; + } + + async.select = async.filter = doParallel(_filter); + + async.selectSeries = async.filterSeries = doSeries(_filter); - // select alias - async.select = async.filter; - async.selectSeries = async.filterSeries; - var _reject = function (eachfn, arr, iterator, callback) { + function _reject(eachfn, arr, iterator, callback) { var results = []; arr = _map(arr, function (x, i) { return {index: i, value: x}; @@ -480,11 +482,11 @@ return x.value; })); }); - }; + } async.reject = doParallel(_reject); async.rejectSeries = doSeries(_reject); - var _detect = function (eachfn, arr, iterator, main_callback) { + function _detect(eachfn, arr, iterator, main_callback) { eachfn(arr, function (x, callback) { iterator(x, function (result) { if (result) { @@ -498,10 +500,11 @@ }, function (err) { main_callback(); }); - }; + } async.detect = doParallel(_detect); async.detectSeries = doSeries(_detect); + async.any = async.some = function (arr, iterator, main_callback) { async.each(arr, function (x, callback) { iterator(x, function (v) { @@ -515,9 +518,8 @@ main_callback(false); }); }; - // any alias - async.any = async.some; + async.all = async.every = function (arr, iterator, main_callback) { async.each(arr, function (x, callback) { iterator(x, function (v) { @@ -531,8 +533,6 @@ main_callback(true); }); }; - // all alias - async.all = async.every; async.sortBy = function (arr, iterator, callback) { async.map(arr, function (x, callback) { @@ -1233,7 +1233,7 @@ return async.seq.apply(null, Array.prototype.reverse.call(arguments)); }; - var _applyEach = function (eachfn, fns /*args...*/) { + function _applyEach(eachfn, fns /*args...*/) { var go = function () { var that = this; var args = _baseSlice(arguments); @@ -1250,7 +1250,7 @@ else { return go; } - }; + } async.applyEach = doParallel(_applyEach); async.applyEachSeries = doSeries(_applyEach); |