Skip to content

Concepts: promises, deferreds, asynchronous operations.

Eugene Lazutkin edited this page Mar 2, 2016 · 3 revisions

The implementation of promises in Heya follows in footsteps of Dojo (and, therefore, Twisted) by providing a compatible base API subset. It refines the concepts inherited from Dojo by painstakingly specifying the API behavior in all corner cases and furnishes a compact and efficient implementation compliant to this spec. An extended API fully compatible with Dojo 1.x could be built with an additional facade layer; it is not required by other Heya facilities and was therefore omitted from the initial version.

Concepts

Existing standards

Years of unregulated implementation of promises have culminated with ES6's Promise. Not all concepts were included, but it provides a baseline API. It is suggested to start by reading the official docs:

  • Promise — read to understand concepts, and get an overview of what functionality is available.
  • Instance methods:
    • [then()](https: //developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Promise/then) — the most important method, which encapsulates the essence of promises.
    • catch() — the asynchronous error handling.
  • Modest means to organize multiple parallel asynchronous operations:
    • all() — run operations waiting when they all finish.
    • race() — run operations waiting for the first one to finish.
  • Produce finalized promises:

But to better understand the underlying ideas, and what was left out on the cutting table of standard promises, please continue to read this document.

Promise

An object encapsulating the result of a potentially asynchronous computation or process that can be extracted with help of its then() or done() methods.

Resolution and rejection

The result of a promise may obtain in one of two forms: resolution, which is a conceptual equivalent of returned value or rejection, which is an equivalent of an exception. Unhandled rejections may be converted to actual Javascript exceptions.

Resolved vs. unresolved promises

An unresolved promise does not yet have its result available but is guaranteed — subject to completion of the associated asynchronous process — to provide one at a later time. A resolved promise does have its result available immediately. The user of a promise should generally be prepared that callbacks passed to then() and/or done() may be executed either synchronously (i.e. before the API method returns) or asynchronously (i.e. after user's code returns control to the interpreter). A rejected promise also has its result — in the form of a rejection — available immediately.

Chaining promises

Method then() is used to extract the result from a promise and issue another, dependent promise which will be resolved after the appropriate callback passed into then() executes and returns a non-promise value or a resolved promise, or after the un-resolved promise returned by the callback is resolved. It is possible to transform promise rejection into resolution and vice versa using chaining.

Method done() is used to end the chain without creating a dependent promise object and is equivalent to then() other than for this performance optimization.

Callbacks and errbacks

Both then() and done() accept two separate callback functions intended to handle resolution and rejection respectively. By convention, the first one is called callback and the second one errback.

Native promise

The implementation of promise provided by Heya; provides additional functionality related to promise cancellation and propagation of progress events. Native promises should not be constructed directly; the native promise constructor is available as Deferred.Promise only for the purposes of instanceof checks.

If a Heya API construct a promise internally, it can be "instrumented" to work with native Heya promises, or a standard one. Any Heya API said to return a promise is guaranteed to return an "instrumented" promise object.

Promise cancellation

An unresolved promise may be cancelled, leading to its rejection; if the promise was obtained by chaining from another promise, the parent promise will also be cancelled in case it has no other dependendents.

THe cancellation is a subject of an underlying promise supporting this functionality.

Foreign promise

An implementation of promise compatible with the same concept, but provided by a 3rd party or standard library. Heya APIs accepting promise arguments are generally expected to interoperate with foreign promises; exceptions are flagged explicitly in the documentation. It is sufficient for a foreign promise to implement then().

Deferred

Also known as a future; an object used to associate the asynchronous process with a promise. In Heya implementation, Deferred is a subclass of a promise that supplies additional API methods to initiate resolution or rejection of a promise chain as well as a provision to cancel the underlying process in case when the associated promise is cancelled.

It is simple to approximate a deferred object with a standard Promise:

function makeDeferred () {
  var resolve, reject,
      promise = new Promise(function executor (res, rej) {
        resolve = res;
        reject  = rej;
      });
  return {
    resolve: resolve,
    reject:  reject,
    promise: promise
  };
}

Alternatively a promise can be approximated by a deferred:

function makePromise (executor) {
  var deferred = new Deferred();
  executor(deferred.resolve.bind(deferred), deferred.reject.bind(deferred));
  return deferred; // assuming this is how we produce a promise
  // return deferred.promise; // FastDeferred uses this way to produce a promise.
}

Class Deferred.Promise

Note: cannot be constructed directly; instances are obtained by applying then() to other native promises or Deferred objects.

then()

var p = promise.then(
  function (value) { ... },
  function (error) { ... },
  function (value) { ... }
);

Associates callback, errback and a progress handler with a promise; returns a dependent promise. Any of the arguments may be omitted or replaced with null; calling then() without arguments simply issues a dependent promise without associating any callbacks.

var p = promise.then(deferred);

Makes deferred, which must be an instance of Deferred.Promise — foreign implementations or dependent promises are not accepted — into a dependent promise, and returns it as the result. The canceller associated with the deferred will never be called as it is no longer the root of the chain. Effects of calling resolve() or reject() on deferred after it's been passed into then() are unspecified.

The net effect of the sequence:

var deferred = new Deferred();
// a sequence of calls to deferred.then() and deferred.done()
var p = promise.then(deferred);

is equivalent to:

var deferred = promise.then();
// a sequence of calls to deferred.then() and deferred.done()
var p = deferred;

Callback

A function that will be called in the event the promise is resolved, receiving as its only argument the value, which is never another promise, that the promise has been resolved to. Resolving a promise executes all callbacks that's been associated with it through calls to then() and done() in a non-specified order. As a result of its execution, the callback may:

  1. Return a defined, non-promise value. In this case, the dependent promise (if any) will be resolved to this value.
  2. Return an undefined value (or, equivalently, not return a value i.e. fall off the end or execute an empty return). In this case, the dependent promise (if any) will be resolved to the same value as was passed into the callback.
  3. Return a promise value. In this case, the dependent promise (if any) will now be treated as a dependent of the returned promise, i.e. it will not be resolved or rejected immediately but only upon resolution or rejection of the promise returned by the callback.
  4. Throw a non-promise value. In this case, the dependent promise will be rejected with this value. Note that throwing an exception creates a separately tracked rejection which, if unhandled, may cause an uncaught exception to be thrown.
  5. Throw a promise value. In this case, the dependent promise will be rejected when the returned promise is either resolved or rejected, with the value that the latter is resolved to or rejected with.

If callback is not specified and the dependent promise exists, the latter is resolved to the same value as the argument that the callback would have received.

Errback

A function that will be called in the event the promise is rejected, receiving as its only argument the value, which is never another promise and typically an Error or other exception object, that the promise has been rejected with. Resolving a promise executes all errbacks that's been associated with it through calls to then() and done() in a non-specified order.

The errback is executed in the same way as the callback with two important differences in treatment of its execution results:

  1. Returning an undefined value by the errback will cause the dependent promise to be rejected with the same value as was passed into the errback. Errback returning undefined is not considered to have handled the rejection.
  2. Any other result of errback's execution (even if it throws an exception of its own) is counted as handling the rejection.

If errback is not specified and the dependent promise exists, the latter is rejected with the same value as the argument that the callback would have received.

Unhandled rejections

A rejection is considered unhandled if, by the time all dependency chains are exhausted it was not handled by any errback. Any rejections — those resulting from a call to Deferred.reject() as well as those resulting from exceptions raised by callbacks and errbacks — that are still unhandled at the time the synchronous part of Deferred.resolve(), Deferred.reject() or Deferred.cancel() finishes executing are either ignored or passed to the user-supplied handler or to ice.uncaught(), depending on the arguments passed into the respective call. Note that ice.uncaught() may throw exceptions that would not be caught by any try-block.

Please note, that it is in general impossible to synchronously determine whether a rejection may still be handled in the future:

var a = new Deferred();
a.reject("later");
a.done(null, function (error) {...});

is conceptually a perfectly valid sequence that would indeed executed an errback, but since it is associated with the promise only after the call to reject() completes, the latter has no choice but treat it as an unhandled exception. Use custom handling or outright suppression of unhandled rejections to in these situations; the default choice is to signal them as errors.

Progress handler

The progress handler is called as a result of executing Deferred.progress() on the root deferred. It is passed the same argument as the original call to Deferred.progress() which should not be a promise. Any results returned or exceptions thrown by the progress handler are ignored.

done()

promise.done(
  function (value) { ... },
  function (error) { ... },
  function (value) { ... }
);

or

promise.done(deferred);

Fully identical to then() except that it does not return a dependent promise, making it a somewhat more efficient alternative when the dependent promise value is not needed. It is possible to call done() without arguments but the resulting sub-chain will not handle rejections and may cause uncaught exceptions should one occur.

Helpers based on then() and done()

These helpers are trivial wrappers on top of then() and done(). They are added here for convenience or compatibility with other packages. Their definitions:

// ...

thenBoth: function (callback) {
	return this.then(callback, callback);
},

doneBoth: function (callback) {
	this.done(callback, callback);
},

"catch": function (errback) {
	return this.then(null, errback);
},

finalCatch: function (errback) {
	this.done(null, errback);
}
// ...

Both xxxBoth() versions attach one callback as both a regular callback and an errback. Usually it is used for a general cleanup regardless of a result of an asynchronous operation.

Both catch() and finalCatch() attach a single errback without a callback. It is there mostly for compatibility with ES6's Promise.

doneBoth() and finalCatch() use done() in their implementation and are meant to be the last link in a processing chain, while thenBoth() and catch() use then(), and return a promise to continue a chain.

protect()

var p = promise.protect();

Returns a dependent promise cancellation of which will never lead to a cancellation of the original promise.

cancel()

promise.cancel(reason, catchUnhandled);

Cancels the promise, leading to a rejection of its direct dependents. Also cancels the parent promise if it has no other dependents. Overall, the effects of the cancellation must be equivalent to the following:

  • Find the nearest ancestor of the cancelled promise that has more than one direct dependent, or, failing that, the root Deferred;
  • If a root Deferred was found (note that this implies that it has at most one direct dependent which must lead to the cancelled promise or otherwise it is the cancelled promise), execute its canceller callback if one was set at construction, passing in reason if supplied, or an instance of Deferred.CancelError. An exception thrown by the canceller is treated as an unhandled rejection, any other result is ignored;
  • Execute all errbacks found upstream of the cancelled promise and downstream of the ancestor promise found during the first step, ignore any results they may return or exceptions they may throw; if reason was supplied in the call to cancel() pass it as the argument into the errbacks, otherwise pass an instance of Deferred.CancelError;
  • Reject the cancelled promise with reason supplied in the call or with an instance of Deferred.CancelError if reason was not supplied.

The optional argument catchUnhandled may take one of the following values:

  • A falsy value, or omitted: any unhandled rejections will be passed to ice.uncaught() and potentially raise an unhandled exception.
  • A truthy non-function value: the unhandled rejections are ignored.
  • A function accepting a single argument: will be called for every unhandled rejection receiving the associated value.