1var parallel = require('../parallel.js'); 2 3// API 4module.exports = ReadableParallel; 5 6/** 7 * Streaming wrapper to `asynckit.parallel` 8 * 9 * @param {array|object} list - array or object (named list) to iterate over 10 * @param {function} iterator - iterator to run 11 * @param {function} callback - invoked when all elements processed 12 * @returns {stream.Readable#} 13 */ 14function ReadableParallel(list, iterator, callback) 15{ 16 if (!(this instanceof ReadableParallel)) 17 { 18 return new ReadableParallel(list, iterator, callback); 19 } 20 21 // turn on object mode 22 ReadableParallel.super_.call(this, {objectMode: true}); 23 24 this._start(parallel, list, iterator, callback); 25} 26