| Index: third_party/google_input_tools/third_party/closure_library/closure/goog/promise/promise.js
|
| diff --git a/third_party/google_input_tools/third_party/closure_library/closure/goog/promise/promise.js b/third_party/google_input_tools/third_party/closure_library/closure/goog/promise/promise.js
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..1c9ef5cf5fcd6fc166882b2ef1883e8e8c556734
|
| --- /dev/null
|
| +++ b/third_party/google_input_tools/third_party/closure_library/closure/goog/promise/promise.js
|
| @@ -0,0 +1,985 @@
|
| +// Copyright 2013 The Closure Library Authors. All Rights Reserved.
|
| +//
|
| +// Licensed under the Apache License, Version 2.0 (the "License");
|
| +// you may not use this file except in compliance with the License.
|
| +// You may obtain a copy of the License at
|
| +//
|
| +// http://www.apache.org/licenses/LICENSE-2.0
|
| +//
|
| +// Unless required by applicable law or agreed to in writing, software
|
| +// distributed under the License is distributed on an "AS-IS" BASIS,
|
| +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
| +// See the License for the specific language governing permissions and
|
| +// limitations under the License.
|
| +
|
| +goog.provide('goog.Promise');
|
| +
|
| +goog.require('goog.Thenable');
|
| +goog.require('goog.asserts');
|
| +goog.require('goog.async.run');
|
| +goog.require('goog.async.throwException');
|
| +goog.require('goog.debug.Error');
|
| +goog.require('goog.promise.Resolver');
|
| +
|
| +
|
| +
|
| +/**
|
| + * Promises provide a result that may be resolved asynchronously. A Promise may
|
| + * be resolved by being fulfilled or rejected with a value, which will be known
|
| + * as the fulfillment value or the rejection reason. Whether fulfilled or
|
| + * rejected, the Promise result is immutable once it is set.
|
| + *
|
| + * Promises may represent results of any type, including undefined. Rejection
|
| + * reasons are typically Errors, but may also be of any type. Closure Promises
|
| + * allow for optional type annotations that enforce that fulfillment values are
|
| + * of the appropriate types at compile time.
|
| + *
|
| + * The result of a Promise is accessible by calling {@code then} and registering
|
| + * {@code onFulfilled} and {@code onRejected} callbacks. Once the Promise
|
| + * resolves, the relevant callbacks are invoked with the fulfillment value or
|
| + * rejection reason as argument. Callbacks are always invoked in the order they
|
| + * were registered, even when additional {@code then} calls are made from inside
|
| + * another callback. A callback is always run asynchronously sometime after the
|
| + * scope containing the registering {@code then} invocation has returned.
|
| + *
|
| + * If a Promise is resolved with another Promise, the first Promise will block
|
| + * until the second is resolved, and then assumes the same result as the second
|
| + * Promise. This allows Promises to depend on the results of other Promises,
|
| + * linking together multiple asynchronous operations.
|
| + *
|
| + * This implementation is compatible with the Promises/A+ specification and
|
| + * passes that specification's conformance test suite. A Closure Promise may be
|
| + * resolved with a Promise instance (or sufficiently compatible Promise-like
|
| + * object) created by other Promise implementations. From the specification,
|
| + * Promise-like objects are known as "Thenables".
|
| + *
|
| + * @see http://promisesaplus.com/
|
| + *
|
| + * @param {function(
|
| + * this:RESOLVER_CONTEXT,
|
| + * function((TYPE|IThenable.<TYPE>|Thenable)=),
|
| + * function(*)): void} resolver
|
| + * Initialization function that is invoked immediately with {@code resolve}
|
| + * and {@code reject} functions as arguments. The Promise is resolved or
|
| + * rejected with the first argument passed to either function.
|
| + * @param {RESOLVER_CONTEXT=} opt_context An optional context for executing the
|
| + * resolver function. If unspecified, the resolver function will be executed
|
| + * in the default scope.
|
| + * @constructor
|
| + * @struct
|
| + * @final
|
| + * @implements {goog.Thenable.<TYPE>}
|
| + * @template TYPE,RESOLVER_CONTEXT
|
| + */
|
| +goog.Promise = function(resolver, opt_context) {
|
| + /**
|
| + * The internal state of this Promise. Either PENDING, FULFILLED, REJECTED, or
|
| + * BLOCKED.
|
| + * @private {goog.Promise.State_}
|
| + */
|
| + this.state_ = goog.Promise.State_.PENDING;
|
| +
|
| + /**
|
| + * The resolved result of the Promise. Immutable once set with either a
|
| + * fulfillment value or rejection reason.
|
| + * @private {*}
|
| + */
|
| + this.result_ = undefined;
|
| +
|
| + /**
|
| + * For Promises created by calling {@code then()}, the originating parent.
|
| + * @private {goog.Promise}
|
| + */
|
| + this.parent_ = null;
|
| +
|
| + /**
|
| + * The list of {@code onFulfilled} and {@code onRejected} callbacks added to
|
| + * this Promise by calls to {@code then()}.
|
| + * @private {Array.<goog.Promise.CallbackEntry_>}
|
| + */
|
| + this.callbackEntries_ = null;
|
| +
|
| + /**
|
| + * Whether the Promise is in the queue of Promises to execute.
|
| + * @private {boolean}
|
| + */
|
| + this.executing_ = false;
|
| +
|
| + if (goog.Promise.UNHANDLED_REJECTION_DELAY > 0) {
|
| + /**
|
| + * A timeout ID used when the {@code UNHANDLED_REJECTION_DELAY} is greater
|
| + * than 0 milliseconds. The ID is set when the Promise is rejected, and
|
| + * cleared only if an {@code onRejected} callback is invoked for the
|
| + * Promise (or one of its descendants) before the delay is exceeded.
|
| + *
|
| + * If the rejection is not handled before the timeout completes, the
|
| + * rejection reason is passed to the unhandled rejection handler.
|
| + * @private {number}
|
| + */
|
| + this.unhandledRejectionId_ = 0;
|
| + } else if (goog.Promise.UNHANDLED_REJECTION_DELAY == 0) {
|
| + /**
|
| + * When the {@code UNHANDLED_REJECTION_DELAY} is set to 0 milliseconds, a
|
| + * boolean that is set if the Promise is rejected, and reset to false if an
|
| + * {@code onRejected} callback is invoked for the Promise (or one of its
|
| + * descendants). If the rejection is not handled before the next timestep,
|
| + * the rejection reason is passed to the unhandled rejection handler.
|
| + * @private {boolean}
|
| + */
|
| + this.hadUnhandledRejection_ = false;
|
| + }
|
| +
|
| + if (goog.Promise.LONG_STACK_TRACES) {
|
| + /**
|
| + * A list of stack trace frames pointing to the locations where this Promise
|
| + * was created or had callbacks added to it. Saved to add additional context
|
| + * to stack traces when an exception is thrown.
|
| + * @private {!Array.<string>}
|
| + */
|
| + this.stack_ = [];
|
| + this.addStackTrace_(new Error('created'));
|
| +
|
| + /**
|
| + * Index of the most recently executed stack frame entry.
|
| + * @private {number}
|
| + */
|
| + this.currentStep_ = 0;
|
| + }
|
| +
|
| + try {
|
| + var self = this;
|
| + resolver.call(
|
| + opt_context,
|
| + function(value) {
|
| + self.resolve_(goog.Promise.State_.FULFILLED, value);
|
| + },
|
| + function(reason) {
|
| + self.resolve_(goog.Promise.State_.REJECTED, reason);
|
| + });
|
| + } catch (e) {
|
| + this.resolve_(goog.Promise.State_.REJECTED, e);
|
| + }
|
| +};
|
| +
|
| +
|
| +/**
|
| + * @define {boolean} Whether traces of {@code then} calls should be included in
|
| + * exceptions thrown
|
| + */
|
| +goog.define('goog.Promise.LONG_STACK_TRACES', false);
|
| +
|
| +
|
| +/**
|
| + * @define {number} The delay in milliseconds before a rejected Promise's reason
|
| + * is passed to the rejection handler. By default, the rejection handler
|
| + * rethrows the rejection reason so that it appears in the developer console or
|
| + * {@code window.onerror} handler.
|
| + *
|
| + * Rejections are rethrown as quickly as possible by default. A negative value
|
| + * disables rejection handling entirely.
|
| + */
|
| +goog.define('goog.Promise.UNHANDLED_REJECTION_DELAY', 0);
|
| +
|
| +
|
| +/**
|
| + * The possible internal states for a Promise. These states are not directly
|
| + * observable to external callers.
|
| + * @enum {number}
|
| + * @private
|
| + */
|
| +goog.Promise.State_ = {
|
| + /** The Promise is waiting for resolution. */
|
| + PENDING: 0,
|
| +
|
| + /** The Promise is blocked waiting for the result of another Thenable. */
|
| + BLOCKED: 1,
|
| +
|
| + /** The Promise has been resolved with a fulfillment value. */
|
| + FULFILLED: 2,
|
| +
|
| + /** The Promise has been resolved with a rejection reason. */
|
| + REJECTED: 3
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Typedef for entries in the callback chain. Each call to {@code then},
|
| + * {@code thenCatch}, or {@code thenAlways} creates an entry containing the
|
| + * functions that may be invoked once the Promise is resolved.
|
| + *
|
| + * @typedef {{
|
| + * child: goog.Promise,
|
| + * onFulfilled: function(*),
|
| + * onRejected: function(*)
|
| + * }}
|
| + * @private
|
| + */
|
| +goog.Promise.CallbackEntry_;
|
| +
|
| +
|
| +/**
|
| + * @param {(TYPE|goog.Thenable.<TYPE>|Thenable)=} opt_value
|
| + * @return {!goog.Promise.<TYPE>} A new Promise that is immediately resolved
|
| + * with the given value.
|
| + * @template TYPE
|
| + */
|
| +goog.Promise.resolve = function(opt_value) {
|
| + return new goog.Promise(function(resolve, reject) {
|
| + resolve(opt_value);
|
| + });
|
| +};
|
| +
|
| +
|
| +/**
|
| + * @param {*=} opt_reason
|
| + * @return {!goog.Promise} A new Promise that is immediately rejected with the
|
| + * given reason.
|
| + */
|
| +goog.Promise.reject = function(opt_reason) {
|
| + return new goog.Promise(function(resolve, reject) {
|
| + reject(opt_reason);
|
| + });
|
| +};
|
| +
|
| +
|
| +/**
|
| + * @param {!Array.<!(goog.Thenable.<TYPE>|Thenable)>} promises
|
| + * @return {!goog.Promise.<TYPE>} A Promise that receives the result of the
|
| + * first Promise (or Promise-like) input to complete.
|
| + * @template TYPE
|
| + */
|
| +goog.Promise.race = function(promises) {
|
| + return new goog.Promise(function(resolve, reject) {
|
| + if (!promises.length) {
|
| + resolve(undefined);
|
| + }
|
| + for (var i = 0, promise; promise = promises[i]; i++) {
|
| + promise.then(resolve, reject);
|
| + }
|
| + });
|
| +};
|
| +
|
| +
|
| +/**
|
| + * @param {!Array.<!(goog.Thenable.<TYPE>|Thenable)>} promises
|
| + * @return {!goog.Promise.<!Array.<TYPE>>} A Promise that receives a list of
|
| + * every fulfilled value once every input Promise (or Promise-like) is
|
| + * successfully fulfilled, or is rejected by the first rejection result.
|
| + * @template TYPE
|
| + */
|
| +goog.Promise.all = function(promises) {
|
| + return new goog.Promise(function(resolve, reject) {
|
| + var toFulfill = promises.length;
|
| + var values = [];
|
| +
|
| + if (!toFulfill) {
|
| + resolve(values);
|
| + return;
|
| + }
|
| +
|
| + var onFulfill = function(index, value) {
|
| + toFulfill--;
|
| + values[index] = value;
|
| + if (toFulfill == 0) {
|
| + resolve(values);
|
| + }
|
| + };
|
| +
|
| + var onReject = function(reason) {
|
| + reject(reason);
|
| + };
|
| +
|
| + for (var i = 0, promise; promise = promises[i]; i++) {
|
| + promise.then(goog.partial(onFulfill, i), onReject);
|
| + }
|
| + });
|
| +};
|
| +
|
| +
|
| +/**
|
| + * @param {!Array.<!(goog.Thenable.<TYPE>|Thenable)>} promises
|
| + * @return {!goog.Promise.<TYPE>} A Promise that receives the value of the first
|
| + * input to be fulfilled, or is rejected with a list of every rejection
|
| + * reason if all inputs are rejected.
|
| + * @template TYPE
|
| + */
|
| +goog.Promise.firstFulfilled = function(promises) {
|
| + return new goog.Promise(function(resolve, reject) {
|
| + var toReject = promises.length;
|
| + var reasons = [];
|
| +
|
| + if (!toReject) {
|
| + resolve(undefined);
|
| + return;
|
| + }
|
| +
|
| + var onFulfill = function(value) {
|
| + resolve(value);
|
| + };
|
| +
|
| + var onReject = function(index, reason) {
|
| + toReject--;
|
| + reasons[index] = reason;
|
| + if (toReject == 0) {
|
| + reject(reasons);
|
| + }
|
| + };
|
| +
|
| + for (var i = 0, promise; promise = promises[i]; i++) {
|
| + promise.then(onFulfill, goog.partial(onReject, i));
|
| + }
|
| + });
|
| +};
|
| +
|
| +
|
| +/**
|
| + * @return {!goog.promise.Resolver.<TYPE>} Resolver wrapping the promise and its
|
| + * resolve / reject functions. Resolving or rejecting the resolver
|
| + * resolves or rejects the promise.
|
| + * @template TYPE
|
| + */
|
| +goog.Promise.withResolver = function() {
|
| + var resolve, reject;
|
| + var promise = new goog.Promise(function(rs, rj) {
|
| + resolve = rs;
|
| + reject = rj;
|
| + });
|
| + return new goog.Promise.Resolver_(promise, resolve, reject);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Adds callbacks that will operate on the result of the Promise, returning a
|
| + * new child Promise.
|
| + *
|
| + * If the Promise is fulfilled, the {@code onFulfilled} callback will be invoked
|
| + * with the fulfillment value as argument, and the child Promise will be
|
| + * fulfilled with the return value of the callback. If the callback throws an
|
| + * exception, the child Promise will be rejected with the thrown value instead.
|
| + *
|
| + * If the Promise is rejected, the {@code onRejected} callback will be invoked
|
| + * with the rejection reason as argument, and the child Promise will be resolved
|
| + * with the return value or rejected with the thrown value of the callback.
|
| + *
|
| + * @override
|
| + */
|
| +goog.Promise.prototype.then = function(
|
| + opt_onFulfilled, opt_onRejected, opt_context) {
|
| +
|
| + if (opt_onFulfilled != null) {
|
| + goog.asserts.assertFunction(opt_onFulfilled,
|
| + 'opt_onFulfilled should be a function.');
|
| + }
|
| + if (opt_onRejected != null) {
|
| + goog.asserts.assertFunction(opt_onRejected,
|
| + 'opt_onRejected should be a function. Did you pass opt_context ' +
|
| + 'as the second argument instead of the third?');
|
| + }
|
| +
|
| + if (goog.Promise.LONG_STACK_TRACES) {
|
| + this.addStackTrace_(new Error('then'));
|
| + }
|
| +
|
| + return this.addChildPromise_(
|
| + goog.isFunction(opt_onFulfilled) ? opt_onFulfilled : null,
|
| + goog.isFunction(opt_onRejected) ? opt_onRejected : null,
|
| + opt_context);
|
| +};
|
| +goog.Thenable.addImplementation(goog.Promise);
|
| +
|
| +
|
| +/**
|
| + * Adds a callback that will be invoked whether the Promise is fulfilled or
|
| + * rejected. The callback receives no argument, and no new child Promise is
|
| + * created. This is useful for ensuring that cleanup takes place after certain
|
| + * asynchronous operations. Callbacks added with {@code thenAlways} will be
|
| + * executed in the same order with other calls to {@code then},
|
| + * {@code thenAlways}, or {@code thenCatch}.
|
| + *
|
| + * Since it does not produce a new child Promise, cancellation propagation is
|
| + * not prevented by adding callbacks with {@code thenAlways}. A Promise that has
|
| + * a cleanup handler added with {@code thenAlways} will be canceled if all of
|
| + * its children created by {@code then} (or {@code thenCatch}) are canceled.
|
| + *
|
| + * @param {function(this:THIS): void} onResolved A function that will be invoked
|
| + * when the Promise is resolved.
|
| + * @param {THIS=} opt_context An optional context object that will be the
|
| + * execution context for the callbacks. By default, functions are executed
|
| + * in the global scope.
|
| + * @return {!goog.Promise.<TYPE>} This Promise, for chaining additional calls.
|
| + * @template THIS
|
| + */
|
| +goog.Promise.prototype.thenAlways = function(onResolved, opt_context) {
|
| + if (goog.Promise.LONG_STACK_TRACES) {
|
| + this.addStackTrace_(new Error('thenAlways'));
|
| + }
|
| +
|
| + var callback = function() {
|
| + try {
|
| + // Ensure that no arguments are passed to onResolved.
|
| + onResolved.call(opt_context);
|
| + } catch (err) {
|
| + goog.Promise.handleRejection_.call(null, err);
|
| + }
|
| + };
|
| +
|
| + this.addCallbackEntry_({
|
| + child: null,
|
| + onRejected: callback,
|
| + onFulfilled: callback
|
| + });
|
| + return this;
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Adds a callback that will be invoked only if the Promise is rejected. This
|
| + * is equivalent to {@code then(null, onRejected)}.
|
| + *
|
| + * @param {!function(this:THIS, *): *} onRejected A function that will be
|
| + * invoked with the rejection reason if the Promise is rejected.
|
| + * @param {THIS=} opt_context An optional context object that will be the
|
| + * execution context for the callbacks. By default, functions are executed
|
| + * in the global scope.
|
| + * @return {!goog.Promise} A new Promise that will receive the result of the
|
| + * callback.
|
| + * @template THIS
|
| + */
|
| +goog.Promise.prototype.thenCatch = function(onRejected, opt_context) {
|
| + if (goog.Promise.LONG_STACK_TRACES) {
|
| + this.addStackTrace_(new Error('thenCatch'));
|
| + }
|
| + return this.addChildPromise_(null, onRejected, opt_context);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Cancels the Promise if it is still pending by rejecting it with a cancel
|
| + * Error. No action is performed if the Promise is already resolved.
|
| + *
|
| + * All child Promises of the canceled Promise will be rejected with the same
|
| + * cancel error, as with normal Promise rejection. If the Promise to be canceled
|
| + * is the only child of a pending Promise, the parent Promise will also be
|
| + * canceled. Cancellation may propagate upward through multiple generations.
|
| + *
|
| + * @param {string=} opt_message An optional debugging message for describing the
|
| + * cancellation reason.
|
| + */
|
| +goog.Promise.prototype.cancel = function(opt_message) {
|
| + if (this.state_ == goog.Promise.State_.PENDING) {
|
| + goog.async.run(function() {
|
| + var err = new goog.Promise.CancellationError(opt_message);
|
| + this.cancelInternal_(err);
|
| + }, this);
|
| + }
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Cancels this Promise with the given error.
|
| + *
|
| + * @param {!Error} err The cancellation error.
|
| + * @private
|
| + */
|
| +goog.Promise.prototype.cancelInternal_ = function(err) {
|
| + if (this.state_ == goog.Promise.State_.PENDING) {
|
| + if (this.parent_) {
|
| + // Cancel the Promise and remove it from the parent's child list.
|
| + this.parent_.cancelChild_(this, err);
|
| + } else {
|
| + this.resolve_(goog.Promise.State_.REJECTED, err);
|
| + }
|
| + }
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Cancels a child Promise from the list of callback entries. If the Promise has
|
| + * not already been resolved, reject it with a cancel error. If there are no
|
| + * other children in the list of callback entries, propagate the cancellation
|
| + * by canceling this Promise as well.
|
| + *
|
| + * @param {!goog.Promise} childPromise The Promise to cancel.
|
| + * @param {!Error} err The cancel error to use for rejecting the Promise.
|
| + * @private
|
| + */
|
| +goog.Promise.prototype.cancelChild_ = function(childPromise, err) {
|
| + if (!this.callbackEntries_) {
|
| + return;
|
| + }
|
| + var childCount = 0;
|
| + var childIndex = -1;
|
| +
|
| + // Find the callback entry for the childPromise, and count whether there are
|
| + // additional child Promises.
|
| + for (var i = 0, entry; entry = this.callbackEntries_[i]; i++) {
|
| + var child = entry.child;
|
| + if (child) {
|
| + childCount++;
|
| + if (child == childPromise) {
|
| + childIndex = i;
|
| + }
|
| + if (childIndex >= 0 && childCount > 1) {
|
| + break;
|
| + }
|
| + }
|
| + }
|
| +
|
| + // If the child Promise was the only child, cancel this Promise as well.
|
| + // Otherwise, reject only the child Promise with the cancel error.
|
| + if (childIndex >= 0) {
|
| + if (this.state_ == goog.Promise.State_.PENDING && childCount == 1) {
|
| + this.cancelInternal_(err);
|
| + } else {
|
| + var callbackEntry = this.callbackEntries_.splice(childIndex, 1)[0];
|
| + this.executeCallback_(
|
| + callbackEntry, goog.Promise.State_.REJECTED, err);
|
| + }
|
| + }
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Adds a callback entry to the current Promise, and schedules callback
|
| + * execution if the Promise has already been resolved.
|
| + *
|
| + * @param {goog.Promise.CallbackEntry_} callbackEntry Record containing
|
| + * {@code onFulfilled} and {@code onRejected} callbacks to execute after
|
| + * the Promise is resolved.
|
| + * @private
|
| + */
|
| +goog.Promise.prototype.addCallbackEntry_ = function(callbackEntry) {
|
| + if ((!this.callbackEntries_ || !this.callbackEntries_.length) &&
|
| + (this.state_ == goog.Promise.State_.FULFILLED ||
|
| + this.state_ == goog.Promise.State_.REJECTED)) {
|
| + this.scheduleCallbacks_();
|
| + }
|
| + if (!this.callbackEntries_) {
|
| + this.callbackEntries_ = [];
|
| + }
|
| + this.callbackEntries_.push(callbackEntry);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Creates a child Promise and adds it to the callback entry list. The result of
|
| + * the child Promise is determined by the state of the parent Promise and the
|
| + * result of the {@code onFulfilled} or {@code onRejected} callbacks as
|
| + * specified in the Promise resolution procedure.
|
| + *
|
| + * @see http://promisesaplus.com/#the__method
|
| + *
|
| + * @param {?function(this:THIS, TYPE):
|
| + * (RESULT|goog.Promise.<RESULT>|Thenable)} onFulfilled A callback that
|
| + * will be invoked if the Promise is fullfilled, or null.
|
| + * @param {?function(this:THIS, *): *} onRejected A callback that will be
|
| + * invoked if the Promise is rejected, or null.
|
| + * @param {THIS=} opt_context An optional execution context for the callbacks.
|
| + * in the default calling context.
|
| + * @return {!goog.Promise} The child Promise.
|
| + * @template RESULT,THIS
|
| + * @private
|
| + */
|
| +goog.Promise.prototype.addChildPromise_ = function(
|
| + onFulfilled, onRejected, opt_context) {
|
| +
|
| + var callbackEntry = {
|
| + child: null,
|
| + onFulfilled: null,
|
| + onRejected: null
|
| + };
|
| +
|
| + callbackEntry.child = new goog.Promise(function(resolve, reject) {
|
| + // Invoke onFulfilled, or resolve with the parent's value if absent.
|
| + callbackEntry.onFulfilled = onFulfilled ? function(value) {
|
| + try {
|
| + var result = onFulfilled.call(opt_context, value);
|
| + resolve(result);
|
| + } catch (err) {
|
| + reject(err);
|
| + }
|
| + } : resolve;
|
| +
|
| + // Invoke onRejected, or reject with the parent's reason if absent.
|
| + callbackEntry.onRejected = onRejected ? function(reason) {
|
| + try {
|
| + var result = onRejected.call(opt_context, reason);
|
| + if (!goog.isDef(result) &&
|
| + reason instanceof goog.Promise.CancellationError) {
|
| + // Propagate cancellation to children if no other result is returned.
|
| + reject(reason);
|
| + } else {
|
| + resolve(result);
|
| + }
|
| + } catch (err) {
|
| + reject(err);
|
| + }
|
| + } : reject;
|
| + });
|
| +
|
| + callbackEntry.child.parent_ = this;
|
| + this.addCallbackEntry_(
|
| + /** @type {goog.Promise.CallbackEntry_} */ (callbackEntry));
|
| + return callbackEntry.child;
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Unblocks the Promise and fulfills it with the given value.
|
| + *
|
| + * @param {TYPE} value
|
| + * @private
|
| + */
|
| +goog.Promise.prototype.unblockAndFulfill_ = function(value) {
|
| + goog.asserts.assert(this.state_ == goog.Promise.State_.BLOCKED);
|
| + this.state_ = goog.Promise.State_.PENDING;
|
| + this.resolve_(goog.Promise.State_.FULFILLED, value);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Unblocks the Promise and rejects it with the given rejection reason.
|
| + *
|
| + * @param {*} reason
|
| + * @private
|
| + */
|
| +goog.Promise.prototype.unblockAndReject_ = function(reason) {
|
| + goog.asserts.assert(this.state_ == goog.Promise.State_.BLOCKED);
|
| + this.state_ = goog.Promise.State_.PENDING;
|
| + this.resolve_(goog.Promise.State_.REJECTED, reason);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Attempts to resolve a Promise with a given resolution state and value. This
|
| + * is a no-op if the given Promise has already been resolved.
|
| + *
|
| + * If the given result is a Thenable (such as another Promise), the Promise will
|
| + * be resolved with the same state and result as the Thenable once it is itself
|
| + * resolved.
|
| + *
|
| + * If the given result is not a Thenable, the Promise will be fulfilled or
|
| + * rejected with that result based on the given state.
|
| + *
|
| + * @see http://promisesaplus.com/#the_promise_resolution_procedure
|
| + *
|
| + * @param {goog.Promise.State_} state
|
| + * @param {*} x The result to apply to the Promise.
|
| + * @private
|
| + */
|
| +goog.Promise.prototype.resolve_ = function(state, x) {
|
| + if (this.state_ != goog.Promise.State_.PENDING) {
|
| + return;
|
| + }
|
| +
|
| + if (this == x) {
|
| + state = goog.Promise.State_.REJECTED;
|
| + x = new TypeError('Promise cannot resolve to itself');
|
| +
|
| + } else if (goog.Thenable.isImplementedBy(x)) {
|
| + x = /** @type {!goog.Thenable} */ (x);
|
| + this.state_ = goog.Promise.State_.BLOCKED;
|
| + x.then(this.unblockAndFulfill_, this.unblockAndReject_, this);
|
| + return;
|
| +
|
| + } else if (goog.isObject(x)) {
|
| + try {
|
| + var then = x['then'];
|
| + if (goog.isFunction(then)) {
|
| + this.tryThen_(x, then);
|
| + return;
|
| + }
|
| + } catch (e) {
|
| + state = goog.Promise.State_.REJECTED;
|
| + x = e;
|
| + }
|
| + }
|
| +
|
| + this.result_ = x;
|
| + this.state_ = state;
|
| + this.scheduleCallbacks_();
|
| +
|
| + if (state == goog.Promise.State_.REJECTED &&
|
| + !(x instanceof goog.Promise.CancellationError)) {
|
| + goog.Promise.addUnhandledRejection_(this, x);
|
| + }
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Attempts to call the {@code then} method on an object in the hopes that it is
|
| + * a Promise-compatible instance. This allows interoperation between different
|
| + * Promise implementations, however a non-compliant object may cause a Promise
|
| + * to hang indefinitely. If the {@code then} method throws an exception, the
|
| + * dependent Promise will be rejected with the thrown value.
|
| + *
|
| + * @see http://promisesaplus.com/#point-70
|
| + *
|
| + * @param {Thenable} thenable An object with a {@code then} method that may be
|
| + * compatible with the Promise/A+ specification.
|
| + * @param {!Function} then The {@code then} method of the Thenable object.
|
| + * @private
|
| + */
|
| +goog.Promise.prototype.tryThen_ = function(thenable, then) {
|
| + this.state_ = goog.Promise.State_.BLOCKED;
|
| + var promise = this;
|
| + var called = false;
|
| +
|
| + var resolve = function(value) {
|
| + if (!called) {
|
| + called = true;
|
| + promise.unblockAndFulfill_(value);
|
| + }
|
| + };
|
| +
|
| + var reject = function(reason) {
|
| + if (!called) {
|
| + called = true;
|
| + promise.unblockAndReject_(reason);
|
| + }
|
| + };
|
| +
|
| + try {
|
| + then.call(thenable, resolve, reject);
|
| + } catch (e) {
|
| + reject(e);
|
| + }
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Executes the pending callbacks of a resolved Promise after a timeout.
|
| + *
|
| + * Section 2.2.4 of the Promises/A+ specification requires that Promise
|
| + * callbacks must only be invoked from a call stack that only contains Promise
|
| + * implementation code, which we accomplish by invoking callback execution after
|
| + * a timeout. If {@code startExecution_} is called multiple times for the same
|
| + * Promise, the callback chain will be evaluated only once. Additional callbacks
|
| + * may be added during the evaluation phase, and will be executed in the same
|
| + * event loop.
|
| + *
|
| + * All Promises added to the waiting list during the same browser event loop
|
| + * will be executed in one batch to avoid using a separate timeout per Promise.
|
| + *
|
| + * @private
|
| + */
|
| +goog.Promise.prototype.scheduleCallbacks_ = function() {
|
| + if (!this.executing_) {
|
| + this.executing_ = true;
|
| + goog.async.run(this.executeCallbacks_, this);
|
| + }
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Executes all pending callbacks for this Promise.
|
| + *
|
| + * @private
|
| + */
|
| +goog.Promise.prototype.executeCallbacks_ = function() {
|
| + while (this.callbackEntries_ && this.callbackEntries_.length) {
|
| + var entries = this.callbackEntries_;
|
| + this.callbackEntries_ = [];
|
| +
|
| + for (var i = 0; i < entries.length; i++) {
|
| + if (goog.Promise.LONG_STACK_TRACES) {
|
| + this.currentStep_++;
|
| + }
|
| + this.executeCallback_(entries[i], this.state_, this.result_);
|
| + }
|
| + }
|
| + this.executing_ = false;
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Executes a pending callback for this Promise. Invokes an {@code onFulfilled}
|
| + * or {@code onRejected} callback based on the resolved state of the Promise.
|
| + *
|
| + * @param {!goog.Promise.CallbackEntry_} callbackEntry An entry containing the
|
| + * onFulfilled and/or onRejected callbacks for this step.
|
| + * @param {goog.Promise.State_} state The resolution status of the Promise,
|
| + * either FULFILLED or REJECTED.
|
| + * @param {*} result The resolved result of the Promise.
|
| + * @private
|
| + */
|
| +goog.Promise.prototype.executeCallback_ = function(
|
| + callbackEntry, state, result) {
|
| + if (state == goog.Promise.State_.FULFILLED) {
|
| + callbackEntry.onFulfilled(result);
|
| + } else {
|
| + this.removeUnhandledRejection_();
|
| + callbackEntry.onRejected(result);
|
| + }
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Records a stack trace entry for functions that call {@code then} or the
|
| + * Promise constructor. May be disabled by unsetting {@code LONG_STACK_TRACES}.
|
| + *
|
| + * @param {!Error} err An Error object created by the calling function for
|
| + * providing a stack trace.
|
| + * @private
|
| + */
|
| +goog.Promise.prototype.addStackTrace_ = function(err) {
|
| + if (goog.Promise.LONG_STACK_TRACES && goog.isString(err.stack)) {
|
| + // Extract the third line of the stack trace, which is the entry for the
|
| + // user function that called into Promise code.
|
| + var trace = err.stack.split('\n', 4)[3];
|
| + var message = err.message;
|
| +
|
| + // Pad the message to align the traces.
|
| + message += Array(11 - message.length).join(' ');
|
| + this.stack_.push(message + trace);
|
| + }
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Adds extra stack trace information to an exception for the list of
|
| + * asynchronous {@code then} calls that have been run for this Promise. Stack
|
| + * trace information is recorded in {@see #addStackTrace_}, and appended to
|
| + * rethrown errors when {@code LONG_STACK_TRACES} is enabled.
|
| + *
|
| + * @param {*} err An unhandled exception captured during callback execution.
|
| + * @private
|
| + */
|
| +goog.Promise.prototype.appendLongStack_ = function(err) {
|
| + if (goog.Promise.LONG_STACK_TRACES &&
|
| + err && goog.isString(err.stack) && this.stack_.length) {
|
| + var longTrace = ['Promise trace:'];
|
| +
|
| + for (var promise = this; promise; promise = promise.parent_) {
|
| + for (var i = this.currentStep_; i >= 0; i--) {
|
| + longTrace.push(promise.stack_[i]);
|
| + }
|
| + longTrace.push('Value: ' +
|
| + '[' + (promise.state_ == goog.Promise.State_.REJECTED ?
|
| + 'REJECTED' : 'FULFILLED') + '] ' +
|
| + '<' + String(promise.result_) + '>');
|
| + }
|
| + err.stack += '\n\n' + longTrace.join('\n');
|
| + }
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Marks this rejected Promise as having being handled. Also marks any parent
|
| + * Promises in the rejected state as handled. The rejection handler will no
|
| + * longer be invoked for this Promise (if it has not been called already).
|
| + *
|
| + * @private
|
| + */
|
| +goog.Promise.prototype.removeUnhandledRejection_ = function() {
|
| + if (goog.Promise.UNHANDLED_REJECTION_DELAY > 0) {
|
| + for (var p = this; p && p.unhandledRejectionId_; p = p.parent_) {
|
| + goog.global.clearTimeout(p.unhandledRejectionId_);
|
| + p.unhandledRejectionId_ = 0;
|
| + }
|
| + } else if (goog.Promise.UNHANDLED_REJECTION_DELAY == 0) {
|
| + for (var p = this; p && p.hadUnhandledRejection_; p = p.parent_) {
|
| + p.hadUnhandledRejection_ = false;
|
| + }
|
| + }
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Marks this rejected Promise as unhandled. If no {@code onRejected} callback
|
| + * is called for this Promise before the {@code UNHANDLED_REJECTION_DELAY}
|
| + * expires, the reason will be passed to the unhandled rejection handler. The
|
| + * handler typically rethrows the rejection reason so that it becomes visible in
|
| + * the developer console.
|
| + *
|
| + * @param {!goog.Promise} promise The rejected Promise.
|
| + * @param {*} reason The Promise rejection reason.
|
| + * @private
|
| + */
|
| +goog.Promise.addUnhandledRejection_ = function(promise, reason) {
|
| + if (goog.Promise.UNHANDLED_REJECTION_DELAY > 0) {
|
| + promise.unhandledRejectionId_ = goog.global.setTimeout(function() {
|
| + promise.appendLongStack_(reason);
|
| + goog.Promise.handleRejection_.call(null, reason);
|
| + }, goog.Promise.UNHANDLED_REJECTION_DELAY);
|
| +
|
| + } else if (goog.Promise.UNHANDLED_REJECTION_DELAY == 0) {
|
| + promise.hadUnhandledRejection_ = true;
|
| + goog.async.run(function() {
|
| + if (promise.hadUnhandledRejection_) {
|
| + promise.appendLongStack_(reason);
|
| + goog.Promise.handleRejection_.call(null, reason);
|
| + }
|
| + });
|
| + }
|
| +};
|
| +
|
| +
|
| +/**
|
| + * A method that is invoked with the rejection reasons for Promises that are
|
| + * rejected but have no {@code onRejected} callbacks registered yet.
|
| + * @type {function(*)}
|
| + * @private
|
| + */
|
| +goog.Promise.handleRejection_ = goog.async.throwException;
|
| +
|
| +
|
| +/**
|
| + * Sets a handler that will be called with reasons from unhandled rejected
|
| + * Promises. If the rejected Promise (or one of its descendants) has an
|
| + * {@code onRejected} callback registered, the rejection will be considered
|
| + * handled, and the rejection handler will not be called.
|
| + *
|
| + * By default, unhandled rejections are rethrown so that the error may be
|
| + * captured by the developer console or a {@code window.onerror} handler.
|
| + *
|
| + * @param {function(*)} handler A function that will be called with reasons from
|
| + * rejected Promises. Defaults to {@code goog.async.throwException}.
|
| + */
|
| +goog.Promise.setUnhandledRejectionHandler = function(handler) {
|
| + goog.Promise.handleRejection_ = handler;
|
| +};
|
| +
|
| +
|
| +
|
| +/**
|
| + * Error used as a rejection reason for canceled Promises.
|
| + *
|
| + * @param {string=} opt_message
|
| + * @constructor
|
| + * @extends {goog.debug.Error}
|
| + * @final
|
| + */
|
| +goog.Promise.CancellationError = function(opt_message) {
|
| + goog.Promise.CancellationError.base(this, 'constructor', opt_message);
|
| +};
|
| +goog.inherits(goog.Promise.CancellationError, goog.debug.Error);
|
| +
|
| +
|
| +/** @override */
|
| +goog.Promise.CancellationError.prototype.name = 'cancel';
|
| +
|
| +
|
| +
|
| +/**
|
| + * Internal implementation of the resolver interface.
|
| + *
|
| + * @param {!goog.Promise.<TYPE>} promise
|
| + * @param {function((TYPE|goog.Promise.<TYPE>|Thenable)=)} resolve
|
| + * @param {function(*): void} reject
|
| + * @implements {goog.promise.Resolver.<TYPE>}
|
| + * @final @struct
|
| + * @constructor
|
| + * @private
|
| + * @template TYPE
|
| + */
|
| +goog.Promise.Resolver_ = function(promise, resolve, reject) {
|
| + /** @const */
|
| + this.promise = promise;
|
| +
|
| + /** @const */
|
| + this.resolve = resolve;
|
| +
|
| + /** @const */
|
| + this.reject = reject;
|
| +};
|
|
|