darkwallet/darkwallet

File async.js has 937 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/*jshint onevar: false, indent:4 */
/*global setImmediate: false, setTimeout: false, console: false */
(function () {

    var async = {};

Function queue has 94 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    async.queue = function (worker, concurrency) {
        if (concurrency === undefined) {
            concurrency = 1;
        }
        function _insert(q, data, pos, callback) {

Function auto has 72 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    async.auto = function (tasks, callback) {
        callback = callback || function () {};
        var keys = _keys(tasks);
        var remainingTasks = keys.length
        if (!remainingTasks) {

Function cargo has 59 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    async.cargo = function (worker, payload) {
        var working     = false,
            tasks       = [];

        var cargo = {

Function _eachLimit has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    var _eachLimit = function (limit) {

        return function (arr, iterator, callback) {
            callback = callback || function () {};
            if (!arr.length || limit <= 0) {

Function memoize has 32 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    async.memoize = function (fn, hasher) {
        var memo = {};
        var queues = {};
        hasher = hasher || function (x) {
            return x;

Function waterfall has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    async.waterfall = function (tasks, callback) {
        callback = callback || function () {};
        if (!_isArray(tasks)) {
          var err = new Error('First argument to waterfall must be an array of functions');
          return callback(err);

Function series has 29 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    async.series = function (tasks, callback) {
        callback = callback || function () {};
        if (_isArray(tasks)) {
            async.mapSeries(tasks, function (fn, callback) {
                if (fn) {

Function _parallel has 29 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    var _parallel = function(eachfn, tasks, callback) {
        callback = callback || function () {};
        if (_isArray(tasks)) {
            eachfn.map(tasks, function (fn, callback) {
                if (fn) {

Function _insert has 28 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        function _insert(q, data, pos, callback) {
          if (!q.started){
            q.started = true;
          }
          if (!_isArray(data)) {

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    var _parallel = function(eachfn, tasks, callback) {
        callback = callback || function () {};
        if (_isArray(tasks)) {
            eachfn.map(tasks, function (fn, callback) {
                if (fn) {

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    async.series = function (tasks, callback) {
        callback = callback || function () {};
        if (_isArray(tasks)) {
            async.mapSeries(tasks, function (fn, callback) {
                if (fn) {

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    async.times = function (count, iterator, callback) {
        var counter = [];
        for (var i = 0; i < count; i++) {
            counter.push(i);
        }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    async.timesSeries = function (count, iterator, callback) {
        var counter = [];
        for (var i = 0; i < count; i++) {
            counter.push(i);
        }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    var doParallel = function (fn) {
        return function () {
            var args = Array.prototype.slice.call(arguments);
            return fn.apply(null, [async.each].concat(args));
        };

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    var doSeries = function (fn) {
        return function () {
            var args = Array.prototype.slice.call(arguments);
            return fn.apply(null, [async.eachSeries].concat(args));
        };

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

        }, function (err) {
            callback(_map(results.sort(function (a, b) {
                return a.index - b.index;
            }), function (x) {
                return x.value;

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

        }, function (err) {
            callback(_map(results.sort(function (a, b) {
                return a.index - b.index;
            }), function (x) {
                return x.value;

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

            resume: function () {
                if (q.paused === false) { return; }
                q.paused = false;
                q.process();
            }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

            pause: function () {
                if (q.paused === true) { return; }
                q.paused = true;
                q.process();
            },

• Read up
  Read up