Sha256: d254fc0dc21eb4608336a462592b44cbbcab954d3b6904a26a4766e03dcce202

Contents?: true

Size: 673 Bytes

Versions: 91

Compression:

Stored size: 673 Bytes

Contents

var parallel = require('../parallel.js');

// API
module.exports = ReadableParallel;

/**
 * Streaming wrapper to `asynckit.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 {stream.Readable#}
 */
function ReadableParallel(list, iterator, callback)
{
  if (!(this instanceof ReadableParallel))
  {
    return new ReadableParallel(list, iterator, callback);
  }

  // turn on object mode
  ReadableParallel.super_.call(this, {objectMode: true});

  this._start(parallel, list, iterator, callback);
}

Version data entries

91 entries across 89 versions & 22 rubygems

Version Path
clapton-0.0.6 lib/clapton/javascripts/node_modules/asynckit/lib/readable_parallel.js
clapton-0.0.5 lib/clapton/javascripts/node_modules/asynckit/lib/readable_parallel.js
clapton-0.0.4 lib/clapton/javascripts/node_modules/asynckit/lib/readable_parallel.js
clapton-0.0.3 lib/clapton/javascripts/node_modules/asynckit/lib/readable_parallel.js
clapton-0.0.2 lib/clapton/javascripts/node_modules/asynckit/lib/readable_parallel.js
clapton-0.0.1 lib/clapton/javascripts/node_modules/asynckit/lib/readable_parallel.js
optimacms-0.1.61 spec/dummy/node_modules/asynckit/lib/readable_parallel.js
waves_lib-0.1.0 js/node_modules/asynckit/lib/readable_parallel.js
reed_sdk-1.0.1 node_modules/asynckit/lib/readable_parallel.js
reed_sdk-1.0.0 node_modules/asynckit/lib/readable_parallel.js
disco_app-0.18.0 test/dummy/node_modules/asynckit/lib/readable_parallel.js
disco_app-0.18.2 test/dummy/node_modules/asynckit/lib/readable_parallel.js
appmap-0.72.2 ./node_modules/asynckit/lib/readable_parallel.js
appmap-0.72.1 ./node_modules/asynckit/lib/readable_parallel.js
appmap-0.72.0 ./node_modules/asynckit/lib/readable_parallel.js
appmap-0.71.0 ./node_modules/asynckit/lib/readable_parallel.js
appmap-0.70.2 ./node_modules/asynckit/lib/readable_parallel.js
appmap-0.70.1 ./node_modules/asynckit/lib/readable_parallel.js
appmap-0.70.0 ./node_modules/asynckit/lib/readable_parallel.js
appmap-0.69.0 ./node_modules/asynckit/lib/readable_parallel.js