diff options
author | Konstantin Tokarev <annulen@yandex.ru> | 2016-08-25 19:20:41 +0300 |
---|---|---|
committer | Konstantin Tokarev <annulen@yandex.ru> | 2017-02-02 12:30:55 +0000 |
commit | 6882a04fb36642862b11efe514251d32070c3d65 (patch) | |
tree | b7959826000b061fd5ccc7512035c7478742f7b0 /Source/JavaScriptCore/builtins/PromiseOperations.js | |
parent | ab6df191029eeeb0b0f16f127d553265659f739e (diff) | |
download | qtwebkit-6882a04fb36642862b11efe514251d32070c3d65.tar.gz |
Imported QtWebKit TP3 (git b57bc6801f1876c3220d5a4bfea33d620d477443)
Change-Id: I3b1d8a2808782c9f34d50240000e20cb38d3680f
Reviewed-by: Konstantin Tokarev <annulen@yandex.ru>
Diffstat (limited to 'Source/JavaScriptCore/builtins/PromiseOperations.js')
-rw-r--r-- | Source/JavaScriptCore/builtins/PromiseOperations.js | 215 |
1 files changed, 215 insertions, 0 deletions
diff --git a/Source/JavaScriptCore/builtins/PromiseOperations.js b/Source/JavaScriptCore/builtins/PromiseOperations.js new file mode 100644 index 000000000..c4e59bb07 --- /dev/null +++ b/Source/JavaScriptCore/builtins/PromiseOperations.js @@ -0,0 +1,215 @@ +/* + * Copyright (C) 2015 Yusuke Suzuki <utatane.tea@gmail.com>. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY APPLE INC. ``AS IS'' AND ANY + * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE + * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR + * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR + * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, + * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, + * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR + * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY + * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE + * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +// @internal + +function isPromise(promise) +{ + "use strict"; + + return @isObject(promise) && !!promise.@promiseState; +} + +function newPromiseReaction(capability, handler) +{ + "use strict"; + + return { + @capabilities: capability, + @handler: handler + }; +} + +function newPromiseCapability(constructor) +{ + "use strict"; + + // FIXME: Check isConstructor(constructor). + if (typeof constructor !== "function") + throw new @TypeError("promise capability requires a constructor function"); + + var promiseCapability = { + @promise: @undefined, + @resolve: @undefined, + @reject: @undefined + }; + + function executor(resolve, reject) + { + if (promiseCapability.@resolve !== @undefined) + throw new @TypeError("resolve function is already set"); + if (promiseCapability.@reject !== @undefined) + throw new @TypeError("reject function is already set"); + + promiseCapability.@resolve = resolve; + promiseCapability.@reject = reject; + } + + var promise = new constructor(executor); + + if (typeof promiseCapability.@resolve !== "function") + throw new @TypeError("executor did not take a resolve function"); + + if (typeof promiseCapability.@reject !== "function") + throw new @TypeError("executor did not take a reject function"); + + promiseCapability.@promise = promise; + + return promiseCapability; +} + +function triggerPromiseReactions(reactions, argument) +{ + "use strict"; + + for (var index = 0, length = reactions.length; index < length; ++index) + @enqueueJob(@promiseReactionJob, [reactions[index], argument]); +} + +function rejectPromise(promise, reason) +{ + "use strict"; + + var reactions = promise.@promiseRejectReactions; + promise.@promiseResult = reason; + promise.@promiseFulfillReactions = @undefined; + promise.@promiseRejectReactions = @undefined; + promise.@promiseState = @promiseStateRejected; + + @InspectorInstrumentation.promiseRejected(promise, reason, reactions); + + @triggerPromiseReactions(reactions, reason); +} + +function fulfillPromise(promise, value) +{ + "use strict"; + + var reactions = promise.@promiseFulfillReactions; + promise.@promiseResult = value; + promise.@promiseFulfillReactions = @undefined; + promise.@promiseRejectReactions = @undefined; + promise.@promiseState = @promiseStateFulfilled; + + @InspectorInstrumentation.promiseFulfilled(promise, value, reactions); + + @triggerPromiseReactions(reactions, value); +} + +function createResolvingFunctions(promise) +{ + "use strict"; + + var alreadyResolved = false; + + var resolve = function (resolution) { + if (alreadyResolved) + return @undefined; + alreadyResolved = true; + + if (resolution === promise) + return @rejectPromise(promise, new @TypeError("Resolve a promise with itself")); + + if (!@isObject(resolution)) + return @fulfillPromise(promise, resolution); + + var then; + try { + then = resolution.then; + } catch (error) { + return @rejectPromise(promise, error); + } + + if (typeof then !== 'function') + return @fulfillPromise(promise, resolution); + + @enqueueJob(@promiseResolveThenableJob, [promise, resolution, then]); + + return @undefined; + }; + + var reject = function (reason) { + if (alreadyResolved) + return @undefined; + alreadyResolved = true; + + return @rejectPromise(promise, reason); + }; + + return { + @resolve: resolve, + @reject: reject + }; +} + +function promiseReactionJob(reaction, argument) +{ + "use strict"; + + var promiseCapability = reaction.@capabilities; + + var result; + try { + result = reaction.@handler.@call(@undefined, argument); + } catch (error) { + return promiseCapability.@reject.@call(@undefined, error); + } + + return promiseCapability.@resolve.@call(@undefined, result); +} + +function promiseResolveThenableJob(promiseToResolve, thenable, then) +{ + "use strict"; + + var resolvingFunctions = @createResolvingFunctions(promiseToResolve); + + try { + return then.@call(thenable, resolvingFunctions.@resolve, resolvingFunctions.@reject); + } catch (error) { + return resolvingFunctions.@reject.@call(@undefined, error); + } +} + +function initializePromise(executor) +{ + "use strict"; + + if (typeof executor !== 'function') + throw new @TypeError("Promise constructor takes a function argument"); + + this.@promiseState = @promiseStatePending; + this.@promiseFulfillReactions = []; + this.@promiseRejectReactions = []; + + var resolvingFunctions = @createResolvingFunctions(this); + try { + executor(resolvingFunctions.@resolve, resolvingFunctions.@reject); + } catch (error) { + return resolvingFunctions.@reject.@call(@undefined, error); + } + + return this; +} |