www.aleph1.co.uk Git - yaffs-website/blob - node_modules/asynckit/parallel.js

   1 var iterate    = require('./lib/iterate.js')
   2   , initState  = require('./lib/state.js')
   3   , terminator = require('./lib/terminator.js')
   4   ;
   5
   6 // Public API
   7 module.exports = parallel;
   8
   9 /**
  10  * Runs iterator over provided array elements in parallel
  11  *
  12  * @param   {array|object} list - array or object (named list) to iterate over
  13  * @param   {function} iterator - iterator to run
  14  * @param   {function} callback - invoked when all elements processed
  15  * @returns {function} - jobs terminator
  16  */
  17 function parallel(list, iterator, callback)
  18 {
  19   var state = initState(list);
  20
  21   while (state.index < (state['keyedList'] || list).length)
  22   {
  23     iterate(list, iterator, state, function(error, result)
  24     {
  25       if (error)
  26       {
  27         callback(error, result);
  28         return;
  29       }
  30
  31       // looks like it's the last one
  32       if (Object.keys(state.jobs).length === 0)
  33       {
  34         callback(null, state.results);
  35         return;
  36       }
  37     });
  38
  39     state.index++;
  40   }
  41
  42   return terminator.bind(state, callback);
  43 }