CoolFace
Apppublic

strong-tie/inbound-calls

sourceHugging Faceupdated 2y agoView on Hugging Face
0likes
readable_parallel.js26 linesDownload Raw Back to lib
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