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