Index: src/js/promise.js |
diff --git a/src/js/promise.js b/src/js/promise.js |
index b4a25846cada38d99e5a3ddadd1cf25f39e2953b..31126b98c510d09c45b1946993ee0794034fbd43 100644 |
--- a/src/js/promise.js |
+++ b/src/js/promise.js |
@@ -12,6 +12,8 @@ |
// Imports |
var InternalArray = utils.InternalArray; |
+var promiseCombinedDeferredSymbol = |
+ utils.ImportNow("promise_combined_deferred_symbol"); |
var promiseHasHandlerSymbol = |
utils.ImportNow("promise_has_handler_symbol"); |
var promiseOnRejectSymbol = utils.ImportNow("promise_on_reject_symbol"); |
@@ -298,7 +300,7 @@ function PromiseAll(iterable) { |
var count = 0; |
var i = 0; |
for (var value of iterable) { |
- this.resolve(value).then( |
+ var promise = this.resolve(value).then( |
// Nested scope to get closure over current i. |
// TODO(arv): Use an inner let binding once available. |
(function(i) { |
@@ -308,6 +310,7 @@ function PromiseAll(iterable) { |
} |
})(i), |
function(r) { deferred.reject(r); }); |
+ SET_PRIVATE(promise, promiseCombinedDeferredSymbol, deferred); |
++i; |
++count; |
} |
@@ -326,9 +329,10 @@ function PromiseRace(iterable) { |
var deferred = %_CallFunction(this, PromiseDeferred); |
try { |
for (var value of iterable) { |
- this.resolve(value).then( |
+ var promise = this.resolve(value).then( |
function(x) { deferred.resolve(x) }, |
function(r) { deferred.reject(r) }); |
+ SET_PRIVATE(promise, promiseCombinedDeferredSymbol, deferred); |
} |
} catch (e) { |
deferred.reject(e) |
@@ -343,8 +347,15 @@ function PromiseHasUserDefinedRejectHandlerRecursive(promise) { |
var queue = GET_PRIVATE(promise, promiseOnRejectSymbol); |
if (IS_UNDEFINED(queue)) return false; |
for (var i = 0; i < queue.length; i += 2) { |
- if (queue[i] != PromiseIdRejectHandler) return true; |
- if (PromiseHasUserDefinedRejectHandlerRecursive(queue[i + 1].promise)) { |
+ var handler = queue[i]; |
+ var promise = queue[i + 1].promise; |
+ if (handler !== PromiseIdRejectHandler) { |
+ var deferred = GET_PRIVATE(promise, promiseCombinedDeferredSymbol); |
+ if (IS_UNDEFINED(deferred)) return true; |
+ if (PromiseHasUserDefinedRejectHandlerRecursive(deferred.promise)) { |
rossberg
2015/10/19 14:24:29
Why the extra conditional and not a tail call?
re
Yang
2015/10/19 16:24:09
A promise is considered to have a reject handler i
|
+ return true; |
+ } |
+ } else if (PromiseHasUserDefinedRejectHandlerRecursive(promise)) { |
return true; |
} |
} |