brianmhunt-mutex-promise
Advanced tools
Comparing version 1.0.12 to 1.0.13
@@ -420,4 +420,32 @@ "use strict"; | ||
// | ||
// MutexPromise.race = function race(iter) { | ||
// FIXME | ||
MutexPromise.race = function race(iter) { | ||
return new MutexPromise(function (resolve, reject) { | ||
var _iteratorNormalCompletion = true; | ||
var _didIteratorError = false; | ||
var _iteratorError = undefined; | ||
try { | ||
for (var _iterator = iter[Symbol.iterator](), _step; !(_iteratorNormalCompletion = (_step = _iterator.next()).done); _iteratorNormalCompletion = true) { | ||
var i = _step.value; | ||
MutexPromise.resolve(i).then(resolve, reject); | ||
} | ||
} catch (err) { | ||
_didIteratorError = true; | ||
_iteratorError = err; | ||
} finally { | ||
try { | ||
if (!_iteratorNormalCompletion && _iterator.return) { | ||
_iterator.return(); | ||
} | ||
} finally { | ||
if (_didIteratorError) { | ||
throw _iteratorError; | ||
} | ||
} | ||
} | ||
}); | ||
}; | ||
// FIXME ^^^ Tracking | ||
// var rp = new MutexPromise(function (res, rej) { | ||
@@ -436,4 +464,2 @@ // var weCatchFor = this.weCatchFor | ||
// | ||
MutexPromise.all = function all(iter) { | ||
@@ -440,0 +466,0 @@ var arr = []; |
{ | ||
"name": "brianmhunt-mutex-promise", | ||
"version": "1.0.12", | ||
"version": "1.0.13", | ||
"description": "Promises with uncaught handling and events", | ||
@@ -5,0 +5,0 @@ "main": "src/MutexPromise.js", |
@@ -355,4 +355,8 @@ "use strict" | ||
// | ||
// MutexPromise.race = function race(iter) { | ||
// FIXME | ||
MutexPromise.race = function race (iter) { | ||
return new MutexPromise((resolve, reject) => { | ||
for (const i of iter) { MutexPromise.resolve(i).then(resolve, reject) } | ||
}) | ||
} | ||
// FIXME ^^^ Tracking | ||
// var rp = new MutexPromise(function (res, rej) { | ||
@@ -359,0 +363,0 @@ // var weCatchFor = this.weCatchFor |
45137
10
1141