maximize-iterator
Advanced tools
+11
-5
@@ -10,3 +10,3 @@ var nextCallback = require('iterator-next-callback'); | ||
| module.exports = function maximizeIterator(iterator, fn, options, callback) { | ||
| module.exports = function maximizeIterator(iterator, fn, options, callback, skipNextTick) { | ||
| if (typeof fn !== 'function') throw new Error('Missing each function'); | ||
@@ -41,3 +41,3 @@ if (typeof options === 'function') { | ||
| processor = null; | ||
| nextTick(err ? callback.bind(null, err) : callback); | ||
| skipNextTick ? callback(err) : nextTick(err ? callback.bind(null, err) : callback); | ||
| }); | ||
@@ -47,7 +47,13 @@ processor(); | ||
| return new Promise(function (resolve, reject) { | ||
| maximizeIterator(iterator, fn, options, function (err) { | ||
| err ? reject(err) : resolve(); | ||
| }); | ||
| maximizeIterator( | ||
| iterator, | ||
| fn, | ||
| options, | ||
| function (err) { | ||
| err ? reject(err) : resolve(); | ||
| }, | ||
| true | ||
| ); | ||
| }); | ||
| } | ||
| }; |
+1
-1
| { | ||
| "name": "maximize-iterator", | ||
| "version": "2.5.0", | ||
| "version": "2.5.1", | ||
| "description": "Maximize the parallel calls of an iterator supporting asyncIterator interface", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
6334
1.65%97
6.59%