?HAMA

Edit File Size: 1.75 KB

/proc/thread-self/root/home/byroehnu/.trash/node_modules11/asynckit/lib/iterate.js

Text Base64

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;
}

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Name	Size	Perms	Modified	Actions
abort.js	497 B	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
async.js	599 B	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
defer.js	441 B	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
iterate.js	1.75 KB	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
readable_asynckit.js	1.57 KB	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
readable_parallel.js	673 B	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
readable_serial.js	655 B	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
readable_serial_ordered.js	941 B	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
state.js	941 B	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
streamify.js	2.89 KB	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive
terminator.js	533 B	lrw-r--r--	2026-02-20 03:53:00	Edit Download recursive recursive

Directory Contents