source: trip-planner-front/node_modules/asynckit/lib/iterate.js@ 6a3a178

Last change on this file since 6a3a178 was 6a3a178, checked in by Ema <ema_spirova@…>, 3 years ago

initial commit

  • Property mode set to 100644
File size: 1.8 KB
Line 
1var async = require('./async.js')
2 , abort = require('./abort.js')
3 ;
4
5// API
6module.exports = iterate;
7
8/**
9 * Iterates over each job object
10 *
11 * @param {array|object} list - array or object (named list) to iterate over
12 * @param {function} iterator - iterator to run
13 * @param {object} state - current job status
14 * @param {function} callback - invoked when all elements processed
15 */
16function iterate(list, iterator, state, callback)
17{
18 // store current index
19 var key = state['keyedList'] ? state['keyedList'][state.index] : state.index;
20
21 state.jobs[key] = runJob(iterator, key, list[key], function(error, output)
22 {
23 // don't repeat yourself
24 // skip secondary callbacks
25 if (!(key in state.jobs))
26 {
27 return;
28 }
29
30 // clean up jobs
31 delete state.jobs[key];
32
33 if (error)
34 {
35 // don't process rest of the results
36 // stop still active jobs
37 // and reset the list
38 abort(state);
39 }
40 else
41 {
42 state.results[key] = output;
43 }
44
45 // return salvaged results
46 callback(error, state.results);
47 });
48}
49
50/**
51 * Runs iterator over provided job element
52 *
53 * @param {function} iterator - iterator to invoke
54 * @param {string|number} key - key/index of the element in the list of jobs
55 * @param {mixed} item - job description
56 * @param {function} callback - invoked after iterator is done with the job
57 * @returns {function|mixed} - job abort function or something else
58 */
59function runJob(iterator, key, item, callback)
60{
61 var aborter;
62
63 // allow shortcut if iterator expects only two arguments
64 if (iterator.length == 2)
65 {
66 aborter = iterator(item, async(callback));
67 }
68 // otherwise go with full three arguments
69 else
70 {
71 aborter = iterator(item, key, async(callback));
72 }
73
74 return aborter;
75}
Note: See TracBrowser for help on using the repository browser.