diff options
author | Lorry Tar Creator <lorry-tar-importer@lorry> | 2017-06-27 06:07:23 +0000 |
---|---|---|
committer | Lorry Tar Creator <lorry-tar-importer@lorry> | 2017-06-27 06:07:23 +0000 |
commit | 1bf1084f2b10c3b47fd1a588d85d21ed0eb41d0c (patch) | |
tree | 46dcd36c86e7fbc6e5df36deb463b33e9967a6f7 /Source/JavaScriptCore/builtins/PromiseOperations.js | |
parent | 32761a6cee1d0dee366b885b7b9c777e67885688 (diff) | |
download | WebKitGtk-tarball-master.tar.gz |
webkitgtk-2.16.5HEADwebkitgtk-2.16.5master
Diffstat (limited to 'Source/JavaScriptCore/builtins/PromiseOperations.js')
-rw-r--r-- | Source/JavaScriptCore/builtins/PromiseOperations.js | 224 |
1 files changed, 224 insertions, 0 deletions
diff --git a/Source/JavaScriptCore/builtins/PromiseOperations.js b/Source/JavaScriptCore/builtins/PromiseOperations.js new file mode 100644 index 000000000..61564e7cd --- /dev/null +++ b/Source/JavaScriptCore/builtins/PromiseOperations.js @@ -0,0 +1,224 @@ +/* + * Copyright (C) 2015 Yusuke Suzuki <utatane.tea@gmail.com>. + * Copyright (C) 2016 Apple Inc. All rights reserved. + * + * 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 + +@globalPrivate +function isPromise(promise) +{ + "use strict"; + + return @isObject(promise) && !!promise.@promiseState; +} + +@globalPrivate +function newPromiseReaction(capability, onFulfilled, onRejected) +{ + "use strict"; + + return { + @capabilities: capability, + @onFulfilled: onFulfilled, + @onRejected: onRejected, + }; +} + +@globalPrivate +function newPromiseCapability(constructor) +{ + "use strict"; + + if (!@isConstructor(constructor)) + @throwTypeError("promise capability requires a constructor function"); + + var promiseCapability = { + @promise: @undefined, + @resolve: @undefined, + @reject: @undefined + }; + + function executor(resolve, reject) + { + if (promiseCapability.@resolve !== @undefined) + @throwTypeError("resolve function is already set"); + if (promiseCapability.@reject !== @undefined) + @throwTypeError("reject function is already set"); + + promiseCapability.@resolve = resolve; + promiseCapability.@reject = reject; + } + + var promise = new constructor(executor); + + if (typeof promiseCapability.@resolve !== "function") + @throwTypeError("executor did not take a resolve function"); + + if (typeof promiseCapability.@reject !== "function") + @throwTypeError("executor did not take a reject function"); + + promiseCapability.@promise = promise; + + return promiseCapability; +} + +@globalPrivate +function triggerPromiseReactions(state, reactions, argument) +{ + "use strict"; + + for (var index = 0, length = reactions.length; index < length; ++index) + @enqueueJob(@promiseReactionJob, [state, reactions[index], argument]); +} + +@globalPrivate +function rejectPromise(promise, reason) +{ + "use strict"; + + var reactions = promise.@promiseReactions; + promise.@promiseResult = reason; + promise.@promiseReactions = @undefined; + promise.@promiseState = @promiseStateRejected; + + @InspectorInstrumentation.promiseRejected(promise, reason, reactions); + + @triggerPromiseReactions(@promiseStateRejected, reactions, reason); +} + +@globalPrivate +function fulfillPromise(promise, value) +{ + "use strict"; + + var reactions = promise.@promiseReactions; + promise.@promiseResult = value; + promise.@promiseReactions = @undefined; + promise.@promiseState = @promiseStateFulfilled; + + @InspectorInstrumentation.promiseFulfilled(promise, value, reactions); + + @triggerPromiseReactions(@promiseStateFulfilled, reactions, value); +} + +@globalPrivate +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 + }; +} + +@globalPrivate +function promiseReactionJob(state, reaction, argument) +{ + "use strict"; + + var promiseCapability = reaction.@capabilities; + + var result; + var handler = (state === @promiseStateFulfilled) ? reaction.@onFulfilled: reaction.@onRejected; + try { + result = handler(argument); + } catch (error) { + return promiseCapability.@reject.@call(@undefined, error); + } + + return promiseCapability.@resolve.@call(@undefined, result); +} + +@globalPrivate +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); + } +} + +@globalPrivate +function initializePromise(executor) +{ + "use strict"; + + if (typeof executor !== 'function') + @throwTypeError("Promise constructor takes a function argument"); + + this.@promiseState = @promiseStatePending; + this.@promiseReactions = []; + + var resolvingFunctions = @createResolvingFunctions(this); + try { + executor(resolvingFunctions.@resolve, resolvingFunctions.@reject); + } catch (error) { + return resolvingFunctions.@reject.@call(@undefined, error); + } + + return this; +} |