123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186 |
- 'use strict';
- //This file contains the ES6 extensions to the core Promises/A+ API
- var Promise = require('./core.js');
- module.exports = Promise;
- /* Static Functions */
- var TRUE = valuePromise(true);
- var FALSE = valuePromise(false);
- var NULL = valuePromise(null);
- var UNDEFINED = valuePromise(undefined);
- var ZERO = valuePromise(0);
- var EMPTYSTRING = valuePromise('');
- function valuePromise(value) {
- var p = new Promise(Promise._D);
- p._y = 1;
- p._z = value;
- return p;
- }
- Promise.resolve = function (value) {
- if (value instanceof Promise) return value;
- if (value === null) return NULL;
- if (value === undefined) return UNDEFINED;
- if (value === true) return TRUE;
- if (value === false) return FALSE;
- if (value === 0) return ZERO;
- if (value === '') return EMPTYSTRING;
- if (typeof value === 'object' || typeof value === 'function') {
- try {
- var then = value.then;
- if (typeof then === 'function') {
- return new Promise(then.bind(value));
- }
- } catch (ex) {
- return new Promise(function (resolve, reject) {
- reject(ex);
- });
- }
- }
- return valuePromise(value);
- };
- var iterableToArray = function (iterable) {
- if (typeof Array.from === 'function') {
- // ES2015+, iterables exist
- iterableToArray = Array.from;
- return Array.from(iterable);
- }
- // ES5, only arrays and array-likes exist
- iterableToArray = function (x) { return Array.prototype.slice.call(x); };
- return Array.prototype.slice.call(iterable);
- }
- Promise.all = function (arr) {
- var args = iterableToArray(arr);
- return new Promise(function (resolve, reject) {
- if (args.length === 0) return resolve([]);
- var remaining = args.length;
- function res(i, val) {
- if (val && (typeof val === 'object' || typeof val === 'function')) {
- if (val instanceof Promise && val.then === Promise.prototype.then) {
- while (val._y === 3) {
- val = val._z;
- }
- if (val._y === 1) return res(i, val._z);
- if (val._y === 2) reject(val._z);
- val.then(function (val) {
- res(i, val);
- }, reject);
- return;
- } else {
- var then = val.then;
- if (typeof then === 'function') {
- var p = new Promise(then.bind(val));
- p.then(function (val) {
- res(i, val);
- }, reject);
- return;
- }
- }
- }
- args[i] = val;
- if (--remaining === 0) {
- resolve(args);
- }
- }
- for (var i = 0; i < args.length; i++) {
- res(i, args[i]);
- }
- });
- };
- function onSettledFulfill(value) {
- return { status: 'fulfilled', value: value };
- }
- function onSettledReject(reason) {
- return { status: 'rejected', reason: reason };
- }
- function mapAllSettled(item) {
- if(item && (typeof item === 'object' || typeof item === 'function')){
- if(item instanceof Promise && item.then === Promise.prototype.then){
- return item.then(onSettledFulfill, onSettledReject);
- }
- var then = item.then;
- if (typeof then === 'function') {
- return new Promise(then.bind(item)).then(onSettledFulfill, onSettledReject)
- }
- }
- return onSettledFulfill(item);
- }
- Promise.allSettled = function (iterable) {
- return Promise.all(iterableToArray(iterable).map(mapAllSettled));
- };
- Promise.reject = function (value) {
- return new Promise(function (resolve, reject) {
- reject(value);
- });
- };
- Promise.race = function (values) {
- return new Promise(function (resolve, reject) {
- iterableToArray(values).forEach(function(value){
- Promise.resolve(value).then(resolve, reject);
- });
- });
- };
- /* Prototype Methods */
- Promise.prototype['catch'] = function (onRejected) {
- return this.then(null, onRejected);
- };
- function getAggregateError(errors){
- if(typeof AggregateError === 'function'){
- return new AggregateError(errors,'All promises were rejected');
- }
- var error = new Error('All promises were rejected');
- error.name = 'AggregateError';
- error.errors = errors;
- return error;
- }
- Promise.any = function promiseAny(values) {
- return new Promise(function(resolve, reject) {
- var promises = iterableToArray(values);
- var hasResolved = false;
- var rejectionReasons = [];
- function resolveOnce(value) {
- if (!hasResolved) {
- hasResolved = true;
- resolve(value);
- }
- }
- function rejectionCheck(reason) {
- rejectionReasons.push(reason);
- if (rejectionReasons.length === promises.length) {
- reject(getAggregateError(rejectionReasons));
- }
- }
- if(promises.length === 0){
- reject(getAggregateError(rejectionReasons));
- } else {
- promises.forEach(function(value){
- Promise.resolve(value).then(resolveOnce, rejectionCheck);
- });
- }
- });
- };
|