summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlexander Early <alexander.early@gmail.com>2015-05-27 23:42:57 -0700
committerAlexander Early <alexander.early@gmail.com>2015-05-27 23:42:57 -0700
commitd35f46067805248be4127030cedda0a80f80b938 (patch)
treedb22d29c55417c43e6d8710ec31ead8f64aa44b8
parent1b258fb79db17ea94e2f6af2372b85f9fef37258 (diff)
downloadasync-d35f46067805248be4127030cedda0a80f80b938.tar.gz
code style changes
-rw-r--r--lib/async.js106
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);