parallel.js
5d92ed19fb80paginated-inlines

parallel.js
View Options

			var iterate = require('./lib/iterate.js')
			, initState = require('./lib/state.js')
			, terminator = require('./lib/terminator.js')
			;

			// Public API
			module.exports = parallel;

			/**
			* Runs iterator over provided array elements in parallel
			*
			* @param {array\|object} list - array or object (named list) to iterate over
			* @param {function} iterator - iterator to run
			* @param {function} callback - invoked when all elements processed
			* @returns {function} - jobs terminator
			*/
			function parallel(list, iterator, callback)
			{
			var state = initState(list);

			while (state.index < (state['keyedList'] \|\| list).length)
			{
			iterate(list, iterator, state, function(error, result)
			{
			if (error)
			{
			callback(error, result);
			return;
			}

			// looks like it's the last one
			if (Object.keys(state.jobs).length === 0)
			{
			callback(null, state.results);
			return;
			}
			});

			state.index++;
			}

			return terminator.bind(state, callback);
			}