Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
abort.js	497 B	-rw-r--r--	2016-06-10 19:07
async.js	599 B	-rw-r--r--	2016-05-20 14:41
defer.js	441 B	-rw-r--r--	2016-05-20 14:41
iterate.js	1.75 KB	-rw-r--r--	2016-06-10 19:07
readable_asynckit.js	1.57 KB	-rw-r--r--	2016-06-12 17:22
readable_parallel.js	673 B	-rw-r--r--	2016-06-12 07:35
readable_serial.js	655 B	-rw-r--r--	2016-06-12 07:07
readable_serial_ordered.js	941 B	-rw-r--r--	2016-06-13 23:14
state.js	941 B	-rw-r--r--	2016-06-11 16:59
streamify.js	2.89 KB	-rw-r--r--	2016-06-12 01:05
terminator.js	533 B	-rw-r--r--	2016-06-11 17:18

Rename

var async = require('./async.js')
  , abort = require('./abort.js')
  ;

// API
module.exports = iterate;

/**
 * Iterates over each job object
 *
 * @param {array|object} list - array or object (named list) to iterate over
 * @param {function} iterator - iterator to run
 * @param {object} state - current job status
 * @param {function} callback - invoked when all elements processed
 */
function iterate(list, iterator, state, callback)
{
  // store current index
  var key = state['keyedList'] ? state['keyedList'][state.index] : state.index;

state.jobs[key] = runJob(iterator, key, list[key], function(error, output)
  {
    // don't repeat yourself
    // skip secondary callbacks
    if (!(key in state.jobs))
    {
      return;
    }

// clean up jobs
    delete state.jobs[key];

if (error)
    {
      // don't process rest of the results
      // stop still active jobs
      // and reset the list
      abort(state);
    }
    else
    {
      state.results[key] = output;
    }

// return salvaged results
    callback(error, state.results);
  });
}

/**
 * Runs iterator over provided job element
 *
 * @param   {function} iterator - iterator to invoke
 * @param   {string|number} key - key/index of the element in the list of jobs
 * @param   {mixed} item - job description
 * @param   {function} callback - invoked after iterator is done with the job
 * @returns {function|mixed} - job abort function or something else
 */
function runJob(iterator, key, item, callback)
{
  var aborter;

// allow shortcut if iterator expects only two arguments
  if (iterator.length == 2)
  {
    aborter = iterator(item, async(callback));
  }
  // otherwise go with full three arguments
  else
  {
    aborter = iterator(item, key, async(callback));
  }

return aborter;
}