/promise

Lightweight JS promise library

Primary LanguageJavaScript

  1. About
  2. Use it
    1. Load the library
    2. Create a promise
    3. Wait for a promise to be resolved/rejected
    4. Chain promises
    5. Follow a promise progress
    6. Combine promises
    7. Dealing with RxJS Observables
  3. API Reference
  4. Tests
  5. In the pipe
  6. References

⚠️ V2's here ! Lots of improvements made :

  • no more Promise#run()
  • unhandled rejections raise exceptions
  • handy utilities added : Promise.resolve, Promise.reject, Promise#catch

About

Promise.js is a simple and lightweight JS promise library inspired by Angular's $q and Kris Kowal's Q.

JS promises just make the code more elegant by avoiding the pyramid of doom of too many nested callbacks when using asynchronous calls.

Promises are now native in most up-to-date JS engines via the constructor Promise but some older browsers may not support them natively or behave with quirks and that is where Promise.js comes to the rescue. Feel free to use/fork/improve it, I will be happy to hear any constructive suggestion! :neckbeard:

Use it

Load the library

Promise.js is exposed as a NodeJS module (preferred) or as a simple global depending on the context of execution. More precisely meaning that :

  • if you use it through NodeJS then it is exposed as a module and you just need to var Promise = require('./Promise.js');
  • otherwise if you included it via a traditionnal <script> tag then it is injected as the global Promise (see Promise.noConflict())

The library comes with an ES6 flavor (Promise.es6.js) that is basically just a rewriting of the original code using arrow functions and const/let instead of var.

Create a promise

You can create a promise from any asynchronous code by wrapping it in an executor function as follow :

var myPromise = new Promise(function (resolve, reject, notify) {
    setTimeout(resolve, 1000, 'Hello world !');
});

The example code above will simply create a promise that will be resolved at least 1000 ms in the future with the value 'Hello world !'.

Upon wrapped code execution, the executor function will be injected 3 callbacks that you can use to resolve/reject the created promise or just notify watchers of its progress. Each of these callbacks accepts one argument that will be in turn passed to callbacks attached via Promise#then, see the Wait for a promise to be resolved/rejected section.

NB1 : Note that as a promise can be whether resolved or rejected only once, multiple calls to resolve/reject won't have any effect, the first to be called will determine the promise final state. On the other hand notify can be called as much as you want, see the Follow a promise progress section.

NB2 : Throwing something in the executor function will have the same effect as calling reject and passing it the thrown value as parameter.

Wait for a promise to be resolved/rejected

Every Promise object has a method Promise#then that allows you to attach callbacks to be executed whenever the promise will solve. Promise#then takes 3 parameters :

  • a resolution callback that will be called (if promise has been resolved) on the value passed to the resolve call.
  • a rejection callback that will be called on the value passed to the reject call (if promise has been rejected).
  • a notification callback, see the Follow a promise progress section.
var myPromise = new Promise(function (resolve, reject, notify) {
    setTimeout(resolve, 1000, 'Hello world !');
});

myPromise.then(function (value) {
    console.log(value);
});

// Will console.log('Hello world !') at least 1000 ms after

In the example above we attached a callback to the resolution of the promise but we can also listen for rejection :

var myPromise = new Promise(function (resolve, reject, notify) {
    setTimeout(function () {

        Math.random() * 10 < 5 ?
            reject('Random < 5') :
            resolve('Random >= 5')
        ;

    }, 1000);
});

myPromise.then(function (value) {
    console.log('Succeeded with :', value);
}, function (error) {
    console.log('Failed with :', error);
});

⚠️ Any promise that is rejected without having a rejection callback attached will raise an exception ! It avoids rejected promises to silently fail and saves you hours of debugging to find out why your code does not work despite no error showing.

⚠️ Promises are always solved asynchronously despite their executor function is called right away. It guarantees you that new Promise and Promise#then will always return a promise that hasn't solved yet. Promise.js tries to use the fastest asynchronous scheduling method, prefering microtasks over macrotasks when available. If you don't know much about these I encourage you to have a look at this amazing post.

Chain promises

Promise#then returns a new promise and therefore allows you to chain calls :

new Promise(function (resolve, reject, notify) {
    setTimeout(resolve, 1000, 'P1');
}).then(function (value) {
    return value.toLowerCase();
}).then(function (value) {
    console.log(value);
});

// Will console.log('p1')

You can also reject any promise in the chain by throwing an error :

new Promise(function (resolve, reject, notify) {
    setTimeout(resolve, 1000, 'P1');
}).then(function (value) {
    throw 'I am not in the mood';
}).then(function (value) {
    console.log(value);
}, function (error) {
    console.log('An error has happened', error);
});

// Will console.log('An error has happened', 'I am not in the mood')

You can also, and it's a very common case, return another promise :

new Promise(function (resolve, reject, notify) {
    setTimeout(resolve, 1000, 2000);
}).then(function (value) {
    return new Promise(function (resolve, reject, notify) {
        setTimeout(resolve, value, 'Timers done !');
    });
}).then(function (value) {
    console.log(value);
});

// Will console.log('Timers done !') at least 3000 ms after

When a promise is resolved but you didn't provided a resolveCallback to Promise#then or is rejected but no rejectCallback was provided, then the new promise returned keeps the parent promise state :

new Promise(function (resolve, reject, notify) {
    setTimeout(reject, 1000, 'Timer failed');
}).then(function (value) {
    console.log('Timer done !');
}).then(null, function (error) {
    console.log('An error has happened', error);
});

// Will console.log('An error has happened', 'Timer failed')

Now imagine replacing all these setTimeout calls by some AJAX ones ! If you're an adept of jQuery's $.ajax you can for example :

new Promise(function (resolve, reject, notify) {
    $.ajax({
        url: 'www.example.com',
        success: function (data, textStatus, jqXHR) {
            resolve(data);
        },
        error: function (jqXHR, textStatus, errorThrown) {
            reject(errorThrown);
        }
    });
}).then(function (data) {
    // Do something with data received
}, function (error) {
    console.log('AJAX call failed :', error);
});

Follow a promise progress

It can be useful for example in a case of file upload to be able to follow the upload promise progress to display a progress indicator to the end user, that's what the notifyCallback of Promise#then is done for !

var p = new Promise(function (resolve, reject, notify) {

    var i = 0;

    var interval = setInterval(function () {

        i += 10;
        notify(i);

        if (i === 100) {
            clearInterval(interval);
            resolve('Upload successful !');
        }

    }, 1000);

}).then(function (value) {
    console.log(value);
}, null, function (notif) {
    console.log('Upload progress : ', notif + '%');
});

// Will display :
// Upload progress : 10% (wait 1000 ms)
// Upload progress : 20% (wait 1000 ms)
// ...                   (wait 1000 ms)
// Upload progress : 100%
// Upload successful !

Combine promises

If running multiple promises in parallel, you can combine them to wait for the whole with Promise.all :

var p1 = new Promise(function (resolve, reject, notify) {
    setTimeout(resolve, 2000, 'p1');
});

var p2 = new Promise(function (resolve, reject, notify) {
    setTimeout(resolve, 1000, 'p2');
});

Promise.all([p1, p2]).then(function (values) {
    console.log(values);
});

// Will console.log(['p1', 'p2']) at least 2000 ms after

Or race them to find the first to solve with Promise.race :

var p1 = new Promise(function (resolve, reject, notify) {
    setTimeout(resolve, 2000, 'p1');
});

var p2 = new Promise(function (resolve, reject, notify) {
    setTimeout(resolve, 1000, 'p2');
});

Promise.race([p1, p2]).then(function (value) {
    console.log(value);
});

// Will console.log('p2') at least 1000 ms after

NB : Note that eventual notifications from combined promises p1 and p2 will be passed in the order they happen to the resulting promise watchers, see the Follow a promise progress section. Notifications from late promises won't no more be catched as soon as a resolution state will be determined.

Dealing with RxJS Observables

If your project uses RxJS Observables like many new Angular apps but you still prefer to manipulate promises, you can create a promise from an Observable the following way :

var observable = new Observable(function (subscriber) {
    subscriber.next(1);
    subscriber.next(2);
    subscriber.next(3);
    subscriber.complete();
});

var promise = Promise.fromObservable(observable);
promise.then(
    function () { console.log('Promise resolved'); },
    function (error) { console.log('Promise rejected'); },
    function (notification) { console.log(notification); }
);

// Will console.log '1', '2', '3' and then 'Promise resolved'

Observable values flow is handled as promise notifications. Promise resolution is triggered by observable completion (therefore with no value) and error stay error regardless the concept Promise/Observable.

NB : If the observable never completes (no call to subscriber.complete), then resulting promise will never resolve.


When you know an observable will return only one value and you want to resolve the promise with it you can set the second parameter of Promise.fromObservable to true to apply early resolution :

var observable = SomeAngularService.http.get(someURL);

var promise = Promise.fromObservable(observable, true);
promise.then(function (data) {
    console.log('Promise resolved with data from HTTP', data);
}, function (error) {
    console.log('Promise rejected');
});

By using early resolution the promise will be resolved with the first emitted value from the observable.

API Reference

Promise#then(resolveCallback, rejectCallback, notifyCallback) attaches resolution callbacks to a promise and returns a new promise on top of resolveCallback or rejectCallback execution depending on promise final status. The notifyCallback can be used to attach a watcher function on the progress of the promise, see the Follow a promise progress section.

The new promise returned will be resolved with the return value of the resolveCallback/rejectCallback or be rejected with the value thrown from them. If a Promise object is explicitly returned then the resulting promise will become that returned promise, see the Chain promises section.


Promise#catch(rejectCallback) is a shortcut for Promise#then(null, rejectCallback) the only difference is, if rejectCallback is omitted, Promise#catch() will still catch the rejection and prevent an exception from rising.


Promise.all([promises]) takes an array of promises and returns a new one that will be whether :

  • resolved with an array of promises resolution values as soon as they all will be resolved. Resolution values are in the same order as passed in promises.
  • rejected with the rejection value of the first rejected promise.

Promise.race([promises]) takes an array of promises and returns a new one that will be resolved/rejected the same way the first finishing passed in promise will be.


Promise.fromObservable(observable, earlyResolution) create a Promise from an RxJS Observable, see the Dealing with RxJS Observables section.


Promise.resolve(value) create a promise that resolves with the value optionally provided.


Promise.reject(value) create a promise that rejects with the value optionally provided.


Promise.noConflict() can be called to avoid naming conflicts with others promise libraries (or native Promise object). It returns the Promise object from this library and restores the original global one.

// Load some promise library that exposes Promise (let's name it lib1)
// Load Promise.js that also exposes Promise
var PromiseJS = Promise.noConflict();
// Promise = lib1 Promise
// PromiseJS = Promise.js Promise

⚠️ Promise.noConflict() is only available if Promise.js has been exposed as a global, see the Load the library section.

Tests

Promise.js comes with its unit tests. You can find them under the "tests" folder of this repository. They are written with QUnit and you can launch them either via your browser with the provided "tests.html" or via the CLI (see previous link for more information).

In the pipe

  • Implement a finally callback.
  • Improve nextTick asynchronous scheduling (Object.observe, MutationObserver).

References