basant307/AI_Governance_Project
048
1var parallel = require('../parallel.js');2 3// API4module.exports = ReadableParallel;5 6/**7 * Streaming wrapper to `asynckit.parallel`8 *9 * @param {array|object} list - array or object (named list) to iterate over10 * @param {function} iterator - iterator to run11 * @param {function} callback - invoked when all elements processed12 * @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 mode22 ReadableParallel.super_.call(this, {objectMode: true});23 24 this._start(parallel, list, iterator, callback);25}26 