Sha256: b79637514db671ef3dcecde523017542c19e63f8eb93c5a5ab42b2f05bcc9a9d
Contents?: true
Size: 655 Bytes
Versions: 91
Compression:
Stored size: 655 Bytes
Contents
var serial = require('../serial.js');
// API
module.exports = ReadableSerial;
/**
* Streaming wrapper to `asynckit.serial`
*
* @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 ReadableSerial(list, iterator, callback)
{
if (!(this instanceof ReadableSerial))
{
return new ReadableSerial(list, iterator, callback);
}
// turn on object mode
ReadableSerial.super_.call(this, {objectMode: true});
this._start(serial, list, iterator, callback);
}
Version data entries
91 entries across 89 versions & 22 rubygems