12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474 |
- function callbacksFor(object) {
- let callbacks = object._promiseCallbacks;
- if (!callbacks) {
- callbacks = object._promiseCallbacks = {};
- }
- return callbacks;
- }
- var EventTarget = {
-
- mixin(object) {
- object.on = this.on;
- object.off = this.off;
- object.trigger = this.trigger;
- object._promiseCallbacks = undefined;
- return object;
- },
-
- on(eventName, callback) {
- if (typeof callback !== 'function') {
- throw new TypeError('Callback must be a function');
- }
- let allCallbacks = callbacksFor(this);
- let callbacks = allCallbacks[eventName];
- if (!callbacks) {
- callbacks = allCallbacks[eventName] = [];
- }
- if (callbacks.indexOf(callback) === -1) {
- callbacks.push(callback);
- }
- },
-
- off(eventName, callback) {
- let allCallbacks = callbacksFor(this);
- if (!callback) {
- allCallbacks[eventName] = [];
- return;
- }
- let callbacks = allCallbacks[eventName];
- let index = callbacks.indexOf(callback);
- if (index !== -1) {
- callbacks.splice(index, 1);
- }
- },
-
- trigger(eventName, options, label) {
- let allCallbacks = callbacksFor(this);
- let callbacks = allCallbacks[eventName];
- if (callbacks) {
-
- let callback;
- for (let i = 0; i < callbacks.length; i++) {
- callback = callbacks[i];
- callback(options, label);
- }
- }
- }
- };
- const config = {
- instrument: false
- };
- EventTarget['mixin'](config);
- function configure(name, value) {
- if (arguments.length === 2) {
- config[name] = value;
- } else {
- return config[name];
- }
- }
- const queue = [];
- function scheduleFlush() {
- setTimeout(() => {
- for (let i = 0; i < queue.length; i++) {
- let entry = queue[i];
- let payload = entry.payload;
- payload.guid = payload.key + payload.id;
- payload.childGuid = payload.key + payload.childId;
- if (payload.error) {
- payload.stack = payload.error.stack;
- }
- config['trigger'](entry.name, entry.payload);
- }
- queue.length = 0;
- }, 50);
- }
- function instrument(eventName, promise, child) {
- if (1 === queue.push({
- name: eventName,
- payload: {
- key: promise._guidKey,
- id: promise._id,
- eventName: eventName,
- detail: promise._result,
- childId: child && child._id,
- label: promise._label,
- timeStamp: Date.now(),
- error: config["instrument-with-stack"] ? new Error(promise._label) : null
- }})) {
- scheduleFlush();
- }
- }
- function resolve$$1(object, label) {
-
- let Constructor = this;
- if (object && typeof object === 'object' && object.constructor === Constructor) {
- return object;
- }
- let promise = new Constructor(noop, label);
- resolve$1(promise, object);
- return promise;
- }
- function withOwnPromise() {
- return new TypeError('A promises callback cannot return that same promise.');
- }
- function objectOrFunction(x) {
- let type = typeof x;
- return x !== null && (type === 'object' || type === 'function');
- }
- function noop() {}
- const PENDING = void 0;
- const FULFILLED = 1;
- const REJECTED = 2;
- const TRY_CATCH_ERROR = { error: null };
- function getThen(promise) {
- try {
- return promise.then;
- } catch(error) {
- TRY_CATCH_ERROR.error = error;
- return TRY_CATCH_ERROR;
- }
- }
- let tryCatchCallback;
- function tryCatcher() {
- try {
- let target = tryCatchCallback;
- tryCatchCallback = null;
- return target.apply(this, arguments);
- } catch(e) {
- TRY_CATCH_ERROR.error = e;
- return TRY_CATCH_ERROR;
- }
- }
- function tryCatch(fn) {
- tryCatchCallback = fn;
- return tryCatcher;
- }
- function handleForeignThenable(promise, thenable, then$$1) {
- config.async(promise => {
- let sealed = false;
- let result = tryCatch(then$$1).call(
- thenable,
- value => {
- if (sealed) { return; }
- sealed = true;
- if (thenable === value) {
- fulfill(promise, value);
- } else {
- resolve$1(promise, value);
- }
- },
- reason => {
- if (sealed) { return; }
- sealed = true;
- reject(promise, reason);
- },
- 'Settle: ' + (promise._label || ' unknown promise')
- );
- if (!sealed && result === TRY_CATCH_ERROR) {
- sealed = true;
- let error = TRY_CATCH_ERROR.error;
- TRY_CATCH_ERROR.error = null;
- reject(promise, error);
- }
- }, promise);
- }
- function handleOwnThenable(promise, thenable) {
- if (thenable._state === FULFILLED) {
- fulfill(promise, thenable._result);
- } else if (thenable._state === REJECTED) {
- thenable._onError = null;
- reject(promise, thenable._result);
- } else {
- subscribe(thenable, undefined, value => {
- if (thenable === value) {
- fulfill(promise, value);
- } else {
- resolve$1(promise, value);
- }
- }, reason => reject(promise, reason));
- }
- }
- function handleMaybeThenable(promise, maybeThenable, then$$1) {
- let isOwnThenable =
- maybeThenable.constructor === promise.constructor &&
- then$$1 === then &&
- promise.constructor.resolve === resolve$$1;
- if (isOwnThenable) {
- handleOwnThenable(promise, maybeThenable);
- } else if (then$$1 === TRY_CATCH_ERROR) {
- let error = TRY_CATCH_ERROR.error;
- TRY_CATCH_ERROR.error = null;
- reject(promise, error);
- } else if (typeof then$$1 === 'function') {
- handleForeignThenable(promise, maybeThenable, then$$1);
- } else {
- fulfill(promise, maybeThenable);
- }
- }
- function resolve$1(promise, value) {
- if (promise === value) {
- fulfill(promise, value);
- } else if (objectOrFunction(value)) {
- handleMaybeThenable(promise, value, getThen(value));
- } else {
- fulfill(promise, value);
- }
- }
- function publishRejection(promise) {
- if (promise._onError) {
- promise._onError(promise._result);
- }
- publish(promise);
- }
- function fulfill(promise, value) {
- if (promise._state !== PENDING) { return; }
- promise._result = value;
- promise._state = FULFILLED;
- if (promise._subscribers.length === 0) {
- if (config.instrument) {
- instrument('fulfilled', promise);
- }
- } else {
- config.async(publish, promise);
- }
- }
- function reject(promise, reason) {
- if (promise._state !== PENDING) { return; }
- promise._state = REJECTED;
- promise._result = reason;
- config.async(publishRejection, promise);
- }
- function subscribe(parent, child, onFulfillment, onRejection) {
- let subscribers = parent._subscribers;
- let length = subscribers.length;
- parent._onError = null;
- subscribers[length] = child;
- subscribers[length + FULFILLED] = onFulfillment;
- subscribers[length + REJECTED] = onRejection;
- if (length === 0 && parent._state) {
- config.async(publish, parent);
- }
- }
- function publish(promise) {
- let subscribers = promise._subscribers;
- let settled = promise._state;
- if (config.instrument) {
- instrument(settled === FULFILLED ? 'fulfilled' : 'rejected', promise);
- }
- if (subscribers.length === 0) { return; }
- let child, callback, result = promise._result;
- for (let i = 0; i < subscribers.length; i += 3) {
- child = subscribers[i];
- callback = subscribers[i + settled];
- if (child) {
- invokeCallback(settled, child, callback, result);
- } else {
- callback(result);
- }
- }
- promise._subscribers.length = 0;
- }
- function invokeCallback(state, promise, callback, result) {
- let hasCallback = typeof callback === 'function';
- let value;
- if (hasCallback) {
- value = tryCatch(callback)(result);
- } else {
- value = result;
- }
- if (promise._state !== PENDING) {
-
- } else if (value === promise) {
- reject(promise, withOwnPromise());
- } else if (value === TRY_CATCH_ERROR) {
- let error = TRY_CATCH_ERROR.error;
- TRY_CATCH_ERROR.error = null;
- reject(promise, error);
- } else if (hasCallback) {
- resolve$1(promise, value);
- } else if (state === FULFILLED) {
- fulfill(promise, value);
- } else if (state === REJECTED) {
- reject(promise, value);
- }
- }
- function initializePromise(promise, resolver) {
- let resolved = false;
- try {
- resolver(value => {
- if (resolved) { return; }
- resolved = true;
- resolve$1(promise, value);
- }, reason => {
- if (resolved) { return; }
- resolved = true;
- reject(promise, reason);
- });
- } catch(e) {
- reject(promise, e);
- }
- }
- function then(onFulfillment, onRejection, label) {
- let parent = this;
- let state = parent._state;
- if (state === FULFILLED && !onFulfillment || state === REJECTED && !onRejection) {
- config.instrument && instrument('chained', parent, parent);
- return parent;
- }
- parent._onError = null;
- let child = new parent.constructor(noop, label);
- let result = parent._result;
- config.instrument && instrument('chained', parent, child);
- if (state === PENDING) {
- subscribe(parent, child, onFulfillment, onRejection);
- } else {
- let callback = state === FULFILLED ? onFulfillment : onRejection;
- config.async(() => invokeCallback(state, child, callback, result));
- }
- return child;
- }
- class Enumerator {
- constructor(Constructor, input, abortOnReject, label) {
- this._instanceConstructor = Constructor;
- this.promise = new Constructor(noop, label);
- this._abortOnReject = abortOnReject;
- this._isUsingOwnPromise = Constructor === Promise;
- this._isUsingOwnResolve = Constructor.resolve === resolve$$1;
- this._init(...arguments);
- }
- _init(Constructor, input) {
- let len = input.length || 0;
- this.length = len;
- this._remaining = len;
- this._result = new Array(len);
- this._enumerate(input);
- }
- _enumerate(input) {
- let length = this.length;
- let promise = this.promise;
- for (let i = 0; promise._state === PENDING && i < length; i++) {
- this._eachEntry(input[i], i, true);
- }
- this._checkFullfillment();
- }
- _checkFullfillment() {
- if (this._remaining === 0) {
- let result = this._result;
- fulfill(this.promise, result);
- this._result = null;
- }
- }
- _settleMaybeThenable(entry, i, firstPass) {
- let c = this._instanceConstructor;
- if (this._isUsingOwnResolve) {
- let then$$1 = getThen(entry);
- if (then$$1 === then && entry._state !== PENDING) {
- entry._onError = null;
- this._settledAt(entry._state, i, entry._result, firstPass);
- } else if (typeof then$$1 !== 'function') {
- this._settledAt(FULFILLED, i, entry, firstPass);
- } else if (this._isUsingOwnPromise) {
- let promise = new c(noop);
- handleMaybeThenable(promise, entry, then$$1);
- this._willSettleAt(promise, i, firstPass);
- } else {
- this._willSettleAt(new c(resolve => resolve(entry)), i, firstPass);
- }
- } else {
- this._willSettleAt(c.resolve(entry), i, firstPass);
- }
- }
- _eachEntry(entry, i, firstPass) {
- if (entry !== null && typeof entry === 'object') {
- this._settleMaybeThenable(entry, i, firstPass);
- } else {
- this._setResultAt(FULFILLED, i, entry, firstPass);
- }
- }
- _settledAt(state, i, value, firstPass) {
- let promise = this.promise;
- if (promise._state === PENDING) {
- if (this._abortOnReject && state === REJECTED) {
- reject(promise, value);
- } else {
- this._setResultAt(state, i, value, firstPass);
- this._checkFullfillment();
- }
- }
- }
- _setResultAt(state, i, value, firstPass) {
- this._remaining--;
- this._result[i] = value;
- }
- _willSettleAt(promise, i, firstPass) {
- subscribe(
- promise, undefined,
- value => this._settledAt(FULFILLED, i, value, firstPass),
- reason => this._settledAt(REJECTED, i, reason, firstPass)
- );
- }
- }
- function setSettledResult(state, i, value) {
- this._remaining--;
- if (state === FULFILLED) {
- this._result[i] = {
- state: 'fulfilled',
- value: value
- };
- } else {
- this._result[i] = {
- state: 'rejected',
- reason: value
- };
- }
- }
- function all(entries, label) {
- if (!Array.isArray(entries)) {
- return this.reject(new TypeError("Promise.all must be called with an array"), label);
- }
- return new Enumerator(this, entries, true , label).promise;
- }
- function race(entries, label) {
-
- let Constructor = this;
- let promise = new Constructor(noop, label);
- if (!Array.isArray(entries)) {
- reject(promise, new TypeError('Promise.race must be called with an array'));
- return promise;
- }
- for (let i = 0; promise._state === PENDING && i < entries.length; i++) {
- subscribe(
- Constructor.resolve(entries[i]), undefined,
- value => resolve$1(promise, value),
- reason => reject(promise, reason)
- );
- }
- return promise;
- }
- function reject$1(reason, label) {
-
- let Constructor = this;
- let promise = new Constructor(noop, label);
- reject(promise, reason);
- return promise;
- }
- const guidKey = 'rsvp_' + Date.now() + '-';
- let counter = 0;
- function needsResolver() {
- throw new TypeError('You must pass a resolver function as the first argument to the promise constructor');
- }
- function needsNew() {
- throw new TypeError("Failed to construct 'Promise': Please use the 'new' operator, this object constructor cannot be called as a function.");
- }
- class Promise {
- constructor(resolver, label) {
- this._id = counter++;
- this._label = label;
- this._state = undefined;
- this._result = undefined;
- this._subscribers = [];
- config.instrument && instrument('created', this);
- if (noop !== resolver) {
- typeof resolver !== 'function' && needsResolver();
- this instanceof Promise ? initializePromise(this, resolver) : needsNew();
- }
- }
- _onError(reason) {
- config.after(() => {
- if (this._onError) {
- config.trigger('error', reason, this._label);
- }
- });
- }
- catch(onRejection, label) {
- return this.then(undefined, onRejection, label);
- }
- finally(callback, label) {
- let promise = this;
- let constructor = promise.constructor;
- if (typeof callback === 'function') {
- return promise.then(value => constructor.resolve(callback()).then(() => value),
- reason => constructor.resolve(callback()).then(() => { throw reason; }));
- }
- return promise.then(callback, callback);
- }
- }
- Promise.cast = resolve$$1;
- Promise.all = all;
- Promise.race = race;
- Promise.resolve = resolve$$1;
- Promise.reject = reject$1;
- Promise.prototype._guidKey = guidKey;
- Promise.prototype.then = then;
- function makeObject(_, argumentNames) {
- let obj = {};
- let length = _.length;
- let args = new Array(length);
- for (let x = 0; x < length; x++) {
- args[x] = _[x];
- }
- for (let i = 0; i < argumentNames.length; i++) {
- let name = argumentNames[i];
- obj[name] = args[i + 1];
- }
- return obj;
- }
- function arrayResult(_) {
- let length = _.length;
- let args = new Array(length - 1);
- for (let i = 1; i < length; i++) {
- args[i - 1] = _[i];
- }
- return args;
- }
- function wrapThenable(then, promise) {
- return {
- then(onFulFillment, onRejection) {
- return then.call(promise, onFulFillment, onRejection);
- }
- };
- }
- function denodeify(nodeFunc, options) {
- let fn = function() {
- let l = arguments.length;
- let args = new Array(l + 1);
- let promiseInput = false;
- for (let i = 0; i < l; ++i) {
- let arg = arguments[i];
- if (!promiseInput) {
-
- promiseInput = needsPromiseInput(arg);
- if (promiseInput === TRY_CATCH_ERROR) {
- let error = TRY_CATCH_ERROR.error;
- TRY_CATCH_ERROR.error = null;
- let p = new Promise(noop);
- reject(p, error);
- return p;
- } else if (promiseInput && promiseInput !== true) {
- arg = wrapThenable(promiseInput, arg);
- }
- }
- args[i] = arg;
- }
- let promise = new Promise(noop);
- args[l] = function(err, val) {
- if (err) {
- reject(promise, err);
- } else if (options === undefined) {
- resolve$1(promise, val);
- } else if (options === true) {
- resolve$1(promise, arrayResult(arguments));
- } else if (Array.isArray(options)) {
- resolve$1(promise, makeObject(arguments, options));
- } else {
- resolve$1(promise, val);
- }
- };
- if (promiseInput) {
- return handlePromiseInput(promise, args, nodeFunc, this);
- } else {
- return handleValueInput(promise, args, nodeFunc, this);
- }
- };
- fn.__proto__ = nodeFunc;
- return fn;
- }
- function handleValueInput(promise, args, nodeFunc, self) {
- let result = tryCatch(nodeFunc).apply(self, args);
- if (result === TRY_CATCH_ERROR) {
- let error = TRY_CATCH_ERROR.error;
- TRY_CATCH_ERROR.error = null;
- reject(promise, error);
- }
- return promise;
- }
- function handlePromiseInput(promise, args, nodeFunc, self){
- return Promise.all(args)
- .then(args => handleValueInput(promise, args, nodeFunc, self));
- }
- function needsPromiseInput(arg) {
- if (arg !== null && typeof arg === 'object') {
- if (arg.constructor === Promise) {
- return true;
- } else {
- return getThen(arg);
- }
- } else {
- return false;
- }
- }
- function all$1(array, label) {
- return Promise.all(array, label);
- }
- class AllSettled extends Enumerator {
- constructor(Constructor, entries, label) {
- super(Constructor, entries, false , label);
- }
- }
- AllSettled.prototype._setResultAt = setSettledResult;
-
- function allSettled(entries, label) {
- if (!Array.isArray(entries)) {
- return Promise.reject(new TypeError("Promise.allSettled must be called with an array"), label);
- }
- return new AllSettled(Promise, entries, label).promise;
- }
- function race$1(array, label) {
- return Promise.race(array, label);
- }
- class PromiseHash extends Enumerator {
- constructor(Constructor, object, abortOnReject = true, label) {
- super(Constructor, object, abortOnReject, label);
- }
- _init(Constructor, object) {
- this._result = {};
- this._enumerate(object);
- }
- _enumerate(input) {
- let keys = Object.keys(input);
- let length = keys.length;
- let promise = this.promise;
- this._remaining = length;
- let key, val;
- for (let i = 0; promise._state === PENDING && i < length; i++) {
- key = keys[i];
- val = input[key];
- this._eachEntry(val, key, true);
- }
- this._checkFullfillment();
- }
- }
- function hash(object, label) {
- return Promise.resolve(object, label)
- .then(function(object) {
- if (object === null || typeof object !== 'object') {
- throw new TypeError("Promise.hash must be called with an object");
- }
- return new PromiseHash(Promise, object, label).promise;
- });
- }
- class HashSettled extends PromiseHash {
- constructor(Constructor, object, label) {
- super(Constructor, object, false, label);
- }
- }
- HashSettled.prototype._setResultAt = setSettledResult;
- function hashSettled(object, label) {
- return Promise.resolve(object, label)
- .then(function(object) {
- if (object === null || typeof object !== 'object') {
- throw new TypeError("hashSettled must be called with an object");
- }
- return new HashSettled(Promise, object, false, label).promise;
- });
- }
- function rethrow(reason) {
- setTimeout(() => {
- throw reason;
- });
- throw reason;
- }
- function defer(label) {
- let deferred = { resolve: undefined, reject: undefined };
- deferred.promise = new Promise((resolve, reject) => {
- deferred.resolve = resolve;
- deferred.reject = reject;
- }, label);
- return deferred;
- }
- class MapEnumerator extends Enumerator {
- constructor(Constructor, entries, mapFn, label) {
- super(Constructor, entries, true, label, mapFn);
- }
- _init(Constructor, input, bool, label, mapFn) {
- let len = input.length || 0;
- this.length = len;
- this._remaining = len;
- this._result = new Array(len);
- this._mapFn = mapFn;
- this._enumerate(input);
- }
- _setResultAt(state, i, value, firstPass) {
- if (firstPass) {
- let val = tryCatch(this._mapFn)(value, i);
- if (val === TRY_CATCH_ERROR) {
- this._settledAt(REJECTED, i, val.error, false);
- } else {
- this._eachEntry(val, i, false);
- }
- } else {
- this._remaining--;
- this._result[i] = value;
- }
- }
- }
- function map(promises, mapFn, label) {
- if (typeof mapFn !== 'function') {
- return Promise.reject(new TypeError("map expects a function as a second argument"), label);
- }
- return Promise.resolve(promises, label)
- .then(function(promises) {
- if (!Array.isArray(promises)) {
- throw new TypeError("map must be called with an array");
- }
- return new MapEnumerator(Promise, promises, mapFn, label).promise;
- });
- }
- function resolve$2(value, label) {
- return Promise.resolve(value, label);
- }
- function reject$2(reason, label) {
- return Promise.reject(reason, label);
- }
- const EMPTY_OBJECT = {};
- class FilterEnumerator extends MapEnumerator {
- _checkFullfillment() {
- if (this._remaining === 0 && this._result !== null) {
- let result = this._result.filter((val) => val !== EMPTY_OBJECT);
- fulfill(this.promise, result);
- this._result = null;
- }
- }
- _setResultAt(state, i, value, firstPass) {
- if (firstPass) {
- this._result[i] = value;
- let val = tryCatch(this._mapFn)(value, i);
- if (val === TRY_CATCH_ERROR) {
- this._settledAt(REJECTED, i, val.error, false);
- } else {
- this._eachEntry(val, i, false);
- }
- } else {
- this._remaining--;
- if (!value) {
- this._result[i] = EMPTY_OBJECT;
- }
- }
- }
- }
- function filter(promises, filterFn, label) {
- if (typeof filterFn !== 'function') {
- return Promise.reject(new TypeError("filter expects function as a second argument"), label);
- }
- return Promise.resolve(promises, label)
- .then(function(promises) {
- if (!Array.isArray(promises)) {
- throw new TypeError("filter must be called with an array");
- }
- return new FilterEnumerator(Promise, promises, filterFn, label).promise;
- });
- }
- let len = 0;
- let vertxNext;
- function asap(callback, arg) {
- queue$1[len] = callback;
- queue$1[len + 1] = arg;
- len += 2;
- if (len === 2) {
-
-
-
- scheduleFlush$1();
- }
- }
- const browserWindow = (typeof window !== 'undefined') ? window : undefined;
- const browserGlobal = browserWindow || {};
- const BrowserMutationObserver = browserGlobal.MutationObserver || browserGlobal.WebKitMutationObserver;
- const isNode = typeof self === 'undefined' &&
- typeof process !== 'undefined' && {}.toString.call(process) === '[object process]';
- const isWorker = typeof Uint8ClampedArray !== 'undefined' &&
- typeof importScripts !== 'undefined' &&
- typeof MessageChannel !== 'undefined';
- function useNextTick() {
- let nextTick = process.nextTick;
-
-
- let version = process.versions.node.match(/^(?:(\d+)\.)?(?:(\d+)\.)?(\*|\d+)$/);
- if (Array.isArray(version) && version[1] === '0' && version[2] === '10') {
- nextTick = setImmediate;
- }
- return () => nextTick(flush);
- }
- function useVertxTimer() {
- if (typeof vertxNext !== 'undefined') {
- return function() {
- vertxNext(flush);
- };
- }
- return useSetTimeout();
- }
- function useMutationObserver() {
- let iterations = 0;
- let observer = new BrowserMutationObserver(flush);
- let node = document.createTextNode('');
- observer.observe(node, { characterData: true });
- return () => node.data = (iterations = ++iterations % 2);
- }
- function useMessageChannel() {
- let channel = new MessageChannel();
- channel.port1.onmessage = flush;
- return () => channel.port2.postMessage(0);
- }
- function useSetTimeout() {
- return () => setTimeout(flush, 1);
- }
- const queue$1 = new Array(1000);
- function flush() {
- for (let i = 0; i < len; i+=2) {
- let callback = queue$1[i];
- let arg = queue$1[i+1];
- callback(arg);
- queue$1[i] = undefined;
- queue$1[i+1] = undefined;
- }
- len = 0;
- }
- function attemptVertex() {
- try {
- const vertx = Function('return this')().require('vertx');
- vertxNext = vertx.runOnLoop || vertx.runOnContext;
- return useVertxTimer();
- } catch(e) {
- return useSetTimeout();
- }
- }
- let scheduleFlush$1;
- if (isNode) {
- scheduleFlush$1 = useNextTick();
- } else if (BrowserMutationObserver) {
- scheduleFlush$1 = useMutationObserver();
- } else if (isWorker) {
- scheduleFlush$1 = useMessageChannel();
- } else if (browserWindow === undefined && typeof require === 'function') {
- scheduleFlush$1 = attemptVertex();
- } else {
- scheduleFlush$1 = useSetTimeout();
- }
- config.async = asap;
- config.after = cb => setTimeout(cb, 0);
- const cast = resolve$2;
- const async = (callback, arg) => config.async(callback, arg);
- function on() {
- config.on(...arguments);
- }
- function off() {
- config.off(...arguments);
- }
- if (typeof window !== 'undefined' && typeof window['__PROMISE_INSTRUMENTATION__'] === 'object') {
- let callbacks = window['__PROMISE_INSTRUMENTATION__'];
- configure('instrument', true);
- for (let eventName in callbacks) {
- if (callbacks.hasOwnProperty(eventName)) {
- on(eventName, callbacks[eventName]);
- }
- }
- }
- var rsvp = {
- asap,
- cast,
- Promise,
- EventTarget,
- all: all$1,
- allSettled,
- race: race$1,
- hash,
- hashSettled,
- rethrow,
- defer,
- denodeify,
- configure,
- on,
- off,
- resolve: resolve$2,
- reject: reject$2,
- map,
- async,
- filter
- };
- export default rsvp;
- export { asap, cast, Promise, EventTarget, all$1 as all, allSettled, race$1 as race, hash, hashSettled, rethrow, defer, denodeify, configure, on, off, resolve$2 as resolve, reject$2 as reject, map, async, filter };
|