Skip to content

Commit

Permalink
code style changes
Browse files Browse the repository at this point in the history
  • Loading branch information
aearly committed May 28, 2015
1 parent 1b258fb commit d35f460
Showing 1 changed file with 53 additions and 53 deletions.
106 changes: 53 additions & 53 deletions lib/async.js
Expand Up @@ -8,7 +8,7 @@
(function () {

var async = {};
var noop = function () {};
function noop() {}

// global on the server, window in the browser
var root, previous_async;
Expand Down Expand Up @@ -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);
Expand All @@ -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 = [];
Expand All @@ -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;
Expand All @@ -107,7 +107,7 @@
result[index] = arr[index + start];
}
return result;
};
}

//// exported async module functions ////

Expand Down Expand Up @@ -147,6 +147,7 @@
}
}

async.forEach =
async.each = function (arr, iterator, callback) {
callback = callback || noop;
if (!arr.length) {
Expand All @@ -169,8 +170,8 @@
}
}
};
async.forEach = async.each;

async.forEachSeries =
async.eachSeries = function (arr, iterator, callback) {
callback = callback || noop;
if (!arr.length) {
Expand All @@ -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;
Expand Down Expand Up @@ -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;
Expand All @@ -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;
Expand Down Expand Up @@ -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 () {};
Expand Down Expand Up @@ -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};
});
Expand All @@ -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) {
Expand All @@ -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};
Expand All @@ -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};
Expand All @@ -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) {
Expand All @@ -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) {
Expand All @@ -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) {
Expand All @@ -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) {
Expand Down Expand Up @@ -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);
Expand All @@ -1250,7 +1250,7 @@
else {
return go;
}
};
}
async.applyEach = doParallel(_applyEach);
async.applyEachSeries = doSeries(_applyEach);

Expand Down

0 comments on commit d35f460

Please sign in to comment.