[](https://travis-ci.org/kaerus/promise.js)
Promise.js
==========
A Promises/A+ library, originally developed for the ArangoDB client.
](https://travis-ci.org/kaerus/promise.js){kind=link}
- Conforming to the Promises/A+ specification.
Example a simple webpage using promises.
<!doctype html>
<html>
<head><title>Promise</title>
<script src="promise.js"></script>
</head>
<body>
<h1 id="h1"></h1>
<h2 id="h2"></h2>
<h2 id="h3"></h2>
<script>
document.getElementById('h1').innerHTML = "Fulfill a promise";
Promise().fulfill("Hello").then(function(a){
var doc = document.getElementById('h2');
doc.innerHTML = a;
return "World!";
}).then(function(b){
var doc = document.getElementById('h3');
doc.innerHTML = b;
});
</script>
</body>
</html>Example of how to use promises for Ajax.
<!doctype html>
<html>
<head><title>Promise</title>
<script src="./promise.js"></script>
</head>
<body>
<h1 id="h1"></h1>
<h2 id="h2"></h2>
<div id="content"></div>
<script>
document.getElementById('h1').innerHTML = "Ajaxed promise";
function getAjax(url) {
var promise = new Promise(),
xhr = new XMLHttpRequest, timer;
/* This will be called after getAjax(...) returns */
xhr.onreadystatechange = function() {
if(xhr.readyState === 4 && xhr.status) {
clearTimeout(timer);
if(xhr.status > 399) promise.reject(xhr.statusText);
else promise.fulfill(xhr.responseText);
}
}
/* send an asynchronous XmlHttp GET request */
xhr.open("GET",url,true);
xhr.send(null);
/* set a timeout that fires after 5 secs */
timer = setTimeout(function() {
xhr.abort();
promise.reject("operation timedout!");
},5000);
/* return this promise */
return promise;
}
/* When the response arives it calls either the fulfilled block or the rejected block. */
getAjax("http://earthquake.usgs.gov/earthquakes/feed/geojson/significant/month").then(function(value){
/* validates JSON data */
var data = JSON.parse(value);
document.getElementById('h2').innerHTML = "Fulfilled";
document.getElementById('content').innerHTML = JSON.stringify(data);
},function(reason){
document.getElementById('h2').innerHTML = "Rejected";
document.getElementById('content').innerHTML = reason;
});
</script>
</body>
</html>/* chaining promises, (undefined blocks are ignored) */
promise = new Promise();
promise.then(function(value){
return value + 1;
}).then(function(value){
if(value < 5) throw "value is to small";
console.log("value:", value);
}).then(undefined,function(error){
/* catch thrown error here */
console.log(error);
});
/* fulfill with a random value */
promise.fulfill(Math.floor(Math.random()*10));/* Multiple fulfillment values can be placed inside an array */
promise().fulfill([1,2,3]).then(function(value) {
console.log("a(%s) b(%s) c(%s)", value[0], value[1], value[2]);
});
/* Use spread() to receive the individual elements as arguments */
promise().fulfill([1,2,3]).spread(function(a,b,c) {
console.log("a(%s) b(%s) c(%s)", a, b, c);
});
/* You can also fulfill with multiple fullfilment arguments. */
promise().fulfill("abc",123,{abc:123}).spread(function(a,b,c) {
console.log("a(%s) b(%s) c(%s)", a, b, c);
});Example how to create a promise around a process making it run asynchronously in your code.
var promisedSync = Promise().when(function(){
var retval = syncProc();
/* if syncProc() throws the error will */
/* end up in the rejection handler. */
if(retval) this.fulfill(retval);
else this.reject("Operation failed");
});
/* Process the result whenever its ready */
promisedSync.then(...);You may also wrap a promise around multiple functions or promises.
var tasks = [];
tasks.push(someFunction);
tasks.push(somePromise);
Promise().when(tasks).then(function(values){
console.log("Tasks returned", values);
}, function(error){
console.log("Tasks failed", error);
});Example with a more refined Ajax wrapper using attached(), abort() & timeout().
// ajax wrapper returning a promise
function Ajax(options,data) {
var res = new Promise(),
req = new XMLHttpRequest;
options = options ? options : {};
data = data ? data : null;
if(typeof options !== 'object') options = {url:options};
if(!options.method) options.method = "get";
if(!options.headers) options.headers = {};
if(!options.timeout) options.timeout = 5000;
if(!options.headers.accept) options.headers.accept = "application/json";
res.attach(req);
function handle(req,res){
var msg = req.responseText,
hdr = parseHeaders(req.getAllResponseHeaders());
if(options.headers.accept.indexOf('json') >= 0)
msg = JSON.parse(msg);
if(req.status < 400) res.fulfill(msg,hdr);
else res.reject(msg);
}
function parseHeaders(h) {
var ret = {}, key, val, i;
h.split('\n').forEach(function(header) {
if((i=header.indexOf(':')) > 0) {
key = header.slice(0,i).replace(/^[\s]+|[\s]+$/g,'').toLowerCase();
val = header.slice(i+1,header.length).replace(/^[\s]+|[\s]+$/g,'');
if(key && key.length) ret[key] = val;
}
});
return ret;
}
req.onreadystatechange = function() {
if(req.readyState === 4 && req.status) {
/* clear response timer */
res.timeout(null);
handle(req,res);
}
}
/* send an asynchronous XmlHttp request */
req.open(options.method,options.url,true);
/* set request headers */
Object.keys(options.headers).forEach(function(header) {
req.setRequestHeader(header,options.headers[header]);
});
/* send request */
req.send(data);
/* set a timeout */
res.timeout(options.timeout);
return res;
}Install the development requirements using npm i -d.
Then run make for executing the tests and building/minifying into dist.
Copyright (c) 2012 Kaerus (kaerus.com), Anders Elo <anders @ kaerus com>.
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.