Diffusion Open Access Compliance Check Tool (OACCT) (paginated-inlines) Browse

rOACCT/node_modules/core-js/modules/es.promise.any.js
f646e1f695a7paginated-inlines

es.promise.any.js
View Options

			'use strict';
			var $ = require('../internals/export');
			var call = require('../internals/function-call');
			var aCallable = require('../internals/a-callable');
			var getBuiltIn = require('../internals/get-built-in');
			var newPromiseCapabilityModule = require('../internals/new-promise-capability');
			var perform = require('../internals/perform');
			var iterate = require('../internals/iterate');

			var PROMISE_ANY_ERROR = 'No one promise resolved';

			// `Promise.any` method
			// https://tc39.es/ecma262/#sec-promise.any
			$({ target: 'Promise', stat: true }, {
			any: function any(iterable) {
			var C = this;
			var AggregateError = getBuiltIn('AggregateError');
			var capability = newPromiseCapabilityModule.f(C);
			var resolve = capability.resolve;
			var reject = capability.reject;
			var result = perform(function () {
			var promiseResolve = aCallable(C.resolve);
			var errors = [];
			var counter = 0;
			var remaining = 1;
			var alreadyResolved = false;
			iterate(iterable, function (promise) {
			var index = counter++;
			var alreadyRejected = false;
			remaining++;
			call(promiseResolve, C, promise).then(function (value) {
			if (alreadyRejected \|\| alreadyResolved) return;
			alreadyResolved = true;
			resolve(value);
			}, function (error) {
			if (alreadyRejected \|\| alreadyResolved) return;
			alreadyRejected = true;
			errors[index] = error;
			--remaining \|\| reject(new AggregateError(errors, PROMISE_ANY_ERROR));
			});
			});
			--remaining \|\| reject(new AggregateError(errors, PROMISE_ANY_ERROR));
			});
			if (result.error) reject(result.value);
			return capability.promise;
			}
			});