Chromium Code Reviews| Index: src/js/promise.js |
| diff --git a/src/js/promise.js b/src/js/promise.js |
| index de9597942c010f52d6dd996fc5faac2000b628ec..025a5069ed38e00a3df3663ff01b3900dff5667c 100644 |
| --- a/src/js/promise.js |
| +++ b/src/js/promise.js |
| @@ -69,13 +69,13 @@ var GlobalPromise = function Promise(resolver) { |
| throw MakeTypeError(kResolverNotAFunction, resolver); |
| var promise = PromiseInit(%NewObject(GlobalPromise, new.target)); |
| + var callbacks = CreateResolvingFunctions(promise); |
| try { |
| %DebugPushPromise(promise, Promise); |
| - var callbacks = CreateResolvingFunctions(promise); |
| resolver(callbacks.resolve, callbacks.reject); |
| } catch (e) { |
| - PromiseReject(promise, e); |
| + callbacks.reject(e); |
|
Dan Ehrenberg
2016/01/04 02:49:15
I think this needs to be %_Call(callbacks.reject,
|
| } finally { |
| %DebugPopPromise(); |
| } |
| @@ -204,11 +204,11 @@ function PromiseResolve(promise, x) { |
| if (IS_CALLABLE(then)) { |
| // PromiseResolveThenableJob |
| return %EnqueueMicrotask(function() { |
| + var callbacks = CreateResolvingFunctions(promise); |
| try { |
| - var callbacks = CreateResolvingFunctions(promise); |
| %_Call(then, x, callbacks.resolve, callbacks.reject); |
| } catch (e) { |
| - PromiseReject(promise, e); |
| + callbacks.reject(promise, e); |
|
Dan Ehrenberg
2016/01/04 02:49:15
Here too
|
| } |
| }); |
| } |
| @@ -362,28 +362,28 @@ function PromiseCast(x) { |
| } |
| function PromiseAll(iterable) { |
| + if (!IS_RECEIVER(this)) { |
| + throw MakeTypeError(kCalledOnNonObject, "Promise.all"); |
| + } |
| + |
| var deferred = NewPromiseCapability(this); |
| var resolutions = []; |
| try { |
| - var count = 0; |
| + var count = 1; |
| var i = 0; |
| for (var value of iterable) { |
| - var reject = function(r) { deferred.reject(r) }; |
| - this.resolve(value).then( |
| - // Nested scope to get closure over current i. |
| - // TODO(arv): Use an inner let binding once available. |
| - (function(i) { |
| - return function(x) { |
| - resolutions[i] = x; |
| - if (--count === 0) deferred.resolve(resolutions); |
| - } |
| - })(i), reject); |
| - SET_PRIVATE(reject, promiseCombinedDeferredSymbol, deferred); |
| - ++i; |
| + resolutions[i] = UNDEFINED; |
| + var nextPromise = this.resolve(value); |
| ++count; |
| + nextPromise.then( |
| + CreateResolveElementFunction(i, resolutions, deferred), |
| + deferred.reject); |
| + SET_PRIVATE(deferred.reject, promiseCombinedDeferredSymbol, deferred); |
| + ++i; |
| } |
| - if (count === 0) { |
| + // 6.d |
| + if (--count === 0) { |
| deferred.resolve(resolutions); |
| } |
| @@ -391,6 +391,16 @@ function PromiseAll(iterable) { |
| deferred.reject(e) |
| } |
| return deferred.promise; |
| + |
| + function CreateResolveElementFunction(index, values, promiseCapability) { |
| + var alreadyCalled = false; |
| + return function(x) { |
| + if (alreadyCalled === true) return; |
| + alreadyCalled = true; |
| + values[index] = x; |
| + if (--count === 0) promiseCapability.resolve(values); |
| + }; |
| + } |
| } |
| function PromiseRace(iterable) { |