Commit 3286bc71 authored by rossberg@chromium.org's avatar rossberg@chromium.org

Promises: some adaptations to spec

- Rename Promise.{resolved,rejected,deferred} to Promise.{resolve,reject,defer}
- Rename Promise.one to Promise.race
- Make all failures asynchronous, EXCEPT type errors for resolver
- Disallow non-construct call to Promise constructor
- Don't make combinators go through public this.defer

Also, don't bother using IsCallable.

R=dslomov@chromium.org, yhirano@chromium.org
BUG=

Review URL: https://codereview.chromium.org/99573002

git-svn-id: http://v8.googlecode.com/svn/branches/bleeding_edge@18515 ce2b1a6d-e550-0410-aec6-3dcde31c8c00
parent 61692bf2
...@@ -109,8 +109,9 @@ var kMessages = { ...@@ -109,8 +109,9 @@ var kMessages = {
invalid_argument: ["invalid_argument"], invalid_argument: ["invalid_argument"],
data_view_not_array_buffer: ["First argument to DataView constructor must be an ArrayBuffer"], data_view_not_array_buffer: ["First argument to DataView constructor must be an ArrayBuffer"],
constructor_not_function: ["Constructor ", "%0", " requires 'new'"], constructor_not_function: ["Constructor ", "%0", " requires 'new'"],
not_a_promise: ["%0", "is not a promise"], not_a_promise: ["%0", " is not a promise"],
promise_cyclic: ["Chaining cycle detected for promise", "%0"], resolver_not_a_function: ["Promise resolver ", "%0", " is not a function"],
promise_cyclic: ["Chaining cycle detected for promise ", "%0"],
array_functions_on_frozen: ["Cannot modify frozen array elements"], array_functions_on_frozen: ["Cannot modify frozen array elements"],
array_functions_change_sealed: ["Cannot add/remove sealed array elements"], array_functions_change_sealed: ["Cannot add/remove sealed array elements"],
// RangeError // RangeError
......
...@@ -62,11 +62,16 @@ function IsPromise(x) { ...@@ -62,11 +62,16 @@ function IsPromise(x) {
function Promise(resolver) { function Promise(resolver) {
if (resolver === promiseRaw) return; if (resolver === promiseRaw) return;
if (!%_IsConstructCall()) throw MakeTypeError('not_a_promise', [this]);
if (typeof resolver !== 'function')
throw MakeTypeError('resolver_not_a_function', [resolver]);
var promise = PromiseInit(this); var promise = PromiseInit(this);
resolver(function(x) { PromiseResolve(promise, x) }, try {
function(r) { PromiseReject(promise, r) }); resolver(function(x) { PromiseResolve(promise, x) },
// TODO(rossberg): current draft makes exception from this call asynchronous, function(r) { PromiseReject(promise, r) });
// but that's probably a mistake. } catch (e) {
PromiseReject(promise, e);
}
} }
function PromiseSet(promise, status, value, onResolve, onReject) { function PromiseSet(promise, status, value, onResolve, onReject) {
...@@ -82,9 +87,10 @@ function PromiseInit(promise) { ...@@ -82,9 +87,10 @@ function PromiseInit(promise) {
} }
function PromiseDone(promise, status, value, promiseQueue) { function PromiseDone(promise, status, value, promiseQueue) {
if (GET_PRIVATE(promise, promiseStatus) !== 0) return; if (GET_PRIVATE(promise, promiseStatus) === 0) {
PromiseEnqueue(value, GET_PRIVATE(promise, promiseQueue)); PromiseEnqueue(value, GET_PRIVATE(promise, promiseQueue));
PromiseSet(promise, status, value); PromiseSet(promise, status, value);
}
} }
function PromiseResolve(promise, x) { function PromiseResolve(promise, x) {
...@@ -219,25 +225,24 @@ function PromiseThen(onResolve, onReject) { ...@@ -219,25 +225,24 @@ function PromiseThen(onResolve, onReject) {
PromiseCoerce.table = new $WeakMap; PromiseCoerce.table = new $WeakMap;
function PromiseCoerce(constructor, x) { function PromiseCoerce(constructor, x) {
var then; if (!(IsPromise(x) || IS_NULL_OR_UNDEFINED(x))) {
if (IsPromise(x)) { var then = x.then;
return x; if (typeof then === 'function') {
} else if (!IS_NULL_OR_UNDEFINED(x) && %IsCallable(then = x.then)) { if (PromiseCoerce.table.has(x)) {
if (PromiseCoerce.table.has(x)) { return PromiseCoerce.table.get(x);
return PromiseCoerce.table.get(x); } else {
} else { var deferred = %_CallFunction(constructor, PromiseDeferred);
var deferred = constructor.deferred(); PromiseCoerce.table.set(x, deferred.promise);
PromiseCoerce.table.set(x, deferred.promise); try {
try { %_CallFunction(x, deferred.resolve, deferred.reject, then);
%_CallFunction(x, deferred.resolve, deferred.reject, then); } catch(e) {
} catch(e) { deferred.reject(e);
deferred.reject(e); }
return deferred.promise;
} }
return deferred.promise;
} }
} else {
return x;
} }
return x;
} }
...@@ -245,39 +250,44 @@ function PromiseCoerce(constructor, x) { ...@@ -245,39 +250,44 @@ function PromiseCoerce(constructor, x) {
function PromiseCast(x) { function PromiseCast(x) {
// TODO(rossberg): cannot do better until we support @@create. // TODO(rossberg): cannot do better until we support @@create.
return IsPromise(x) ? x : this.resolved(x); return IsPromise(x) ? x : this.resolve(x);
} }
function PromiseAll(values) { function PromiseAll(values) {
var deferred = this.deferred(); var deferred = %_CallFunction(this, PromiseDeferred);
var resolutions = []; var resolutions = [];
var count = values.length; try {
if (count === 0) { var count = values.length;
deferred.resolve(resolutions); if (count === 0) {
} else { deferred.resolve(resolutions);
for (var i = 0; i < values.length; ++i) { } else {
this.cast(values[i]).chain( for (var i = 0; i < values.length; ++i) {
function(i, x) { this.cast(values[i]).chain(
resolutions[i] = x; function(i, x) {
if (--count === 0) deferred.resolve(resolutions); resolutions[i] = x;
}.bind(UNDEFINED, i), // TODO(rossberg): use let loop once available if (--count === 0) deferred.resolve(resolutions);
function(r) { }.bind(UNDEFINED, i), // TODO(rossberg): use let loop once available
if (count > 0) { count = 0; deferred.reject(r) } function(r) { deferred.reject(r) }
} );
); }
} }
} catch (e) {
deferred.reject(e)
} }
return deferred.promise; return deferred.promise;
} }
function PromiseOne(values) { // a.k.a. race function PromiseOne(values) {
var deferred = this.deferred(); var deferred = %_CallFunction(this, PromiseDeferred);
var done = false; try {
for (var i = 0; i < values.length; ++i) { for (var i = 0; i < values.length; ++i) {
this.cast(values[i]).chain( this.cast(values[i]).chain(
function(x) { if (!done) { done = true; deferred.resolve(x) } }, function(x) { deferred.resolve(x) },
function(r) { if (!done) { done = true; deferred.reject(r) } } function(r) { deferred.reject(r) }
); );
}
} catch (e) {
deferred.reject(e)
} }
return deferred.promise; return deferred.promise;
} }
...@@ -288,11 +298,11 @@ function SetUpPromise() { ...@@ -288,11 +298,11 @@ function SetUpPromise() {
%CheckIsBootstrapping() %CheckIsBootstrapping()
global.Promise = $Promise; global.Promise = $Promise;
InstallFunctions($Promise, DONT_ENUM, [ InstallFunctions($Promise, DONT_ENUM, [
"deferred", PromiseDeferred, "defer", PromiseDeferred,
"resolved", PromiseResolved, "resolve", PromiseResolved,
"rejected", PromiseRejected, "reject", PromiseRejected,
"all", PromiseAll, "all", PromiseAll,
"one", PromiseOne, "race", PromiseOne,
"cast", PromiseCast "cast", PromiseCast
]); ]);
InstallFunctions($Promise.prototype, DONT_ENUM, [ InstallFunctions($Promise.prototype, DONT_ENUM, [
......
...@@ -2663,14 +2663,6 @@ RUNTIME_FUNCTION(MaybeObject*, Runtime_SpecialArrayFunctions) { ...@@ -2663,14 +2663,6 @@ RUNTIME_FUNCTION(MaybeObject*, Runtime_SpecialArrayFunctions) {
} }
RUNTIME_FUNCTION(MaybeObject*, Runtime_IsCallable) {
SealHandleScope shs(isolate);
ASSERT(args.length() == 1);
CONVERT_ARG_CHECKED(Object, obj, 0);
return isolate->heap()->ToBoolean(obj->IsCallable());
}
RUNTIME_FUNCTION(MaybeObject*, Runtime_IsClassicModeFunction) { RUNTIME_FUNCTION(MaybeObject*, Runtime_IsClassicModeFunction) {
SealHandleScope shs(isolate); SealHandleScope shs(isolate);
ASSERT(args.length() == 1); ASSERT(args.length() == 1);
......
...@@ -64,7 +64,6 @@ namespace internal { ...@@ -64,7 +64,6 @@ namespace internal {
F(ToFastProperties, 1, 1) \ F(ToFastProperties, 1, 1) \
F(FinishArrayPrototypeSetup, 1, 1) \ F(FinishArrayPrototypeSetup, 1, 1) \
F(SpecialArrayFunctions, 1, 1) \ F(SpecialArrayFunctions, 1, 1) \
F(IsCallable, 1, 1) \
F(IsClassicModeFunction, 1, 1) \ F(IsClassicModeFunction, 1, 1) \
F(GetDefaultReceiver, 1, 1) \ F(GetDefaultReceiver, 1, 1) \
\ \
......
This diff is collapsed.
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment