187 lines
		
	
	
		
			5.1 KiB
		
	
	
	
		
			JavaScript
		
	
	
	
	
	
			
		
		
	
	
			187 lines
		
	
	
		
			5.1 KiB
		
	
	
	
		
			JavaScript
		
	
	
	
	
	
"use strict";
 | 
						|
module.exports = function(Promise, INTERNAL, tryConvertToPromise,
 | 
						|
    apiRejection, Proxyable) {
 | 
						|
var util = require("./util");
 | 
						|
var isArray = util.isArray;
 | 
						|
 | 
						|
function toResolutionValue(val) {
 | 
						|
    switch(val) {
 | 
						|
    case -2: return [];
 | 
						|
    case -3: return {};
 | 
						|
    case -6: return new Map();
 | 
						|
    }
 | 
						|
}
 | 
						|
 | 
						|
function PromiseArray(values) {
 | 
						|
    var promise = this._promise = new Promise(INTERNAL);
 | 
						|
    if (values instanceof Promise) {
 | 
						|
        promise._propagateFrom(values, 3);
 | 
						|
        values.suppressUnhandledRejections();
 | 
						|
    }
 | 
						|
    promise._setOnCancel(this);
 | 
						|
    this._values = values;
 | 
						|
    this._length = 0;
 | 
						|
    this._totalResolved = 0;
 | 
						|
    this._init(undefined, -2);
 | 
						|
}
 | 
						|
util.inherits(PromiseArray, Proxyable);
 | 
						|
 | 
						|
PromiseArray.prototype.length = function () {
 | 
						|
    return this._length;
 | 
						|
};
 | 
						|
 | 
						|
PromiseArray.prototype.promise = function () {
 | 
						|
    return this._promise;
 | 
						|
};
 | 
						|
 | 
						|
PromiseArray.prototype._init = function init(_, resolveValueIfEmpty) {
 | 
						|
    var values = tryConvertToPromise(this._values, this._promise);
 | 
						|
    if (values instanceof Promise) {
 | 
						|
        values = values._target();
 | 
						|
        var bitField = values._bitField;
 | 
						|
        ;
 | 
						|
        this._values = values;
 | 
						|
 | 
						|
        if (((bitField & 50397184) === 0)) {
 | 
						|
            this._promise._setAsyncGuaranteed();
 | 
						|
            return values._then(
 | 
						|
                init,
 | 
						|
                this._reject,
 | 
						|
                undefined,
 | 
						|
                this,
 | 
						|
                resolveValueIfEmpty
 | 
						|
           );
 | 
						|
        } else if (((bitField & 33554432) !== 0)) {
 | 
						|
            values = values._value();
 | 
						|
        } else if (((bitField & 16777216) !== 0)) {
 | 
						|
            return this._reject(values._reason());
 | 
						|
        } else {
 | 
						|
            return this._cancel();
 | 
						|
        }
 | 
						|
    }
 | 
						|
    values = util.asArray(values);
 | 
						|
    if (values === null) {
 | 
						|
        var err = apiRejection(
 | 
						|
            "expecting an array or an iterable object but got " + util.classString(values)).reason();
 | 
						|
        this._promise._rejectCallback(err, false);
 | 
						|
        return;
 | 
						|
    }
 | 
						|
 | 
						|
    if (values.length === 0) {
 | 
						|
        if (resolveValueIfEmpty === -5) {
 | 
						|
            this._resolveEmptyArray();
 | 
						|
        }
 | 
						|
        else {
 | 
						|
            this._resolve(toResolutionValue(resolveValueIfEmpty));
 | 
						|
        }
 | 
						|
        return;
 | 
						|
    }
 | 
						|
    this._iterate(values);
 | 
						|
};
 | 
						|
 | 
						|
PromiseArray.prototype._iterate = function(values) {
 | 
						|
    var len = this.getActualLength(values.length);
 | 
						|
    this._length = len;
 | 
						|
    this._values = this.shouldCopyValues() ? new Array(len) : this._values;
 | 
						|
    var result = this._promise;
 | 
						|
    var isResolved = false;
 | 
						|
    var bitField = null;
 | 
						|
    for (var i = 0; i < len; ++i) {
 | 
						|
        var maybePromise = tryConvertToPromise(values[i], result);
 | 
						|
 | 
						|
        if (maybePromise instanceof Promise) {
 | 
						|
            maybePromise = maybePromise._target();
 | 
						|
            bitField = maybePromise._bitField;
 | 
						|
        } else {
 | 
						|
            bitField = null;
 | 
						|
        }
 | 
						|
 | 
						|
        if (isResolved) {
 | 
						|
            if (bitField !== null) {
 | 
						|
                maybePromise.suppressUnhandledRejections();
 | 
						|
            }
 | 
						|
        } else if (bitField !== null) {
 | 
						|
            if (((bitField & 50397184) === 0)) {
 | 
						|
                maybePromise._proxy(this, i);
 | 
						|
                this._values[i] = maybePromise;
 | 
						|
            } else if (((bitField & 33554432) !== 0)) {
 | 
						|
                isResolved = this._promiseFulfilled(maybePromise._value(), i);
 | 
						|
            } else if (((bitField & 16777216) !== 0)) {
 | 
						|
                isResolved = this._promiseRejected(maybePromise._reason(), i);
 | 
						|
            } else {
 | 
						|
                isResolved = this._promiseCancelled(i);
 | 
						|
            }
 | 
						|
        } else {
 | 
						|
            isResolved = this._promiseFulfilled(maybePromise, i);
 | 
						|
        }
 | 
						|
    }
 | 
						|
    if (!isResolved) result._setAsyncGuaranteed();
 | 
						|
};
 | 
						|
 | 
						|
PromiseArray.prototype._isResolved = function () {
 | 
						|
    return this._values === null;
 | 
						|
};
 | 
						|
 | 
						|
PromiseArray.prototype._resolve = function (value) {
 | 
						|
    this._values = null;
 | 
						|
    this._promise._fulfill(value);
 | 
						|
};
 | 
						|
 | 
						|
PromiseArray.prototype._cancel = function() {
 | 
						|
    if (this._isResolved() || !this._promise._isCancellable()) return;
 | 
						|
    this._values = null;
 | 
						|
    this._promise._cancel();
 | 
						|
};
 | 
						|
 | 
						|
PromiseArray.prototype._reject = function (reason) {
 | 
						|
    this._values = null;
 | 
						|
    this._promise._rejectCallback(reason, false);
 | 
						|
};
 | 
						|
 | 
						|
PromiseArray.prototype._promiseFulfilled = function (value, index) {
 | 
						|
    this._values[index] = value;
 | 
						|
    var totalResolved = ++this._totalResolved;
 | 
						|
    if (totalResolved >= this._length) {
 | 
						|
        this._resolve(this._values);
 | 
						|
        return true;
 | 
						|
    }
 | 
						|
    return false;
 | 
						|
};
 | 
						|
 | 
						|
PromiseArray.prototype._promiseCancelled = function() {
 | 
						|
    this._cancel();
 | 
						|
    return true;
 | 
						|
};
 | 
						|
 | 
						|
PromiseArray.prototype._promiseRejected = function (reason) {
 | 
						|
    this._totalResolved++;
 | 
						|
    this._reject(reason);
 | 
						|
    return true;
 | 
						|
};
 | 
						|
 | 
						|
PromiseArray.prototype._resultCancelled = function() {
 | 
						|
    if (this._isResolved()) return;
 | 
						|
    var values = this._values;
 | 
						|
    this._cancel();
 | 
						|
    if (values instanceof Promise) {
 | 
						|
        values.cancel();
 | 
						|
    } else {
 | 
						|
        for (var i = 0; i < values.length; ++i) {
 | 
						|
            if (values[i] instanceof Promise) {
 | 
						|
                values[i].cancel();
 | 
						|
            }
 | 
						|
        }
 | 
						|
    }
 | 
						|
};
 | 
						|
 | 
						|
PromiseArray.prototype.shouldCopyValues = function () {
 | 
						|
    return true;
 | 
						|
};
 | 
						|
 | 
						|
PromiseArray.prototype.getActualLength = function (len) {
 | 
						|
    return len;
 | 
						|
};
 | 
						|
 | 
						|
return PromiseArray;
 | 
						|
};
 |