Diffusion Open Access Compliance Check Tool (OACCT) (dev) Browse

rOACCT/node_modules/core-js/modules/esnext.async-iterator.flat-map.js
b7129946b228dev

esnext.async-iterator.flat-map.js
View Options

			'use strict';
			var $ = require('../internals/export');
			var call = require('../internals/function-call');
			var aCallable = require('../internals/a-callable');
			var anObject = require('../internals/an-object');
			var isObject = require('../internals/is-object');
			var getIteratorDirect = require('../internals/get-iterator-direct');
			var createAsyncIteratorProxy = require('../internals/async-iterator-create-proxy');
			var createIterResultObject = require('../internals/create-iter-result-object');
			var getAsyncIteratorFlattenable = require('../internals/get-async-iterator-flattenable');
			var closeAsyncIteration = require('../internals/async-iterator-close');

			var AsyncIteratorProxy = createAsyncIteratorProxy(function (Promise) {
			var state = this;
			var iterator = state.iterator;
			var mapper = state.mapper;

			return new Promise(function (resolve, reject) {
			var doneAndReject = function (error) {
			state.done = true;
			reject(error);
			};

			var ifAbruptCloseAsyncIterator = function (error) {
			closeAsyncIteration(iterator, doneAndReject, error, doneAndReject);
			};

			var outerLoop = function () {
			try {
			Promise.resolve(anObject(call(state.next, iterator))).then(function (step) {
			try {
			if (anObject(step).done) {
			state.done = true;
			resolve(createIterResultObject(undefined, true));
			} else {
			var value = step.value;
			try {
			var result = mapper(value, state.counter++);

			var handler = function (mapped) {
			try {
			state.inner = getAsyncIteratorFlattenable(mapped);
			innerLoop();
			} catch (error4) { ifAbruptCloseAsyncIterator(error4); }
			};

			if (isObject(result)) Promise.resolve(result).then(handler, ifAbruptCloseAsyncIterator);
			else handler(result);
			} catch (error3) { ifAbruptCloseAsyncIterator(error3); }
			}
			} catch (error2) { doneAndReject(error2); }
			}, doneAndReject);
			} catch (error) { doneAndReject(error); }
			};

			var innerLoop = function () {
			var inner = state.inner;
			if (inner) {
			try {
			Promise.resolve(anObject(call(inner.next, inner.iterator))).then(function (result) {
			try {
			if (anObject(result).done) {
			state.inner = null;
			outerLoop();
			} else resolve(createIterResultObject(result.value, false));
			} catch (error1) { ifAbruptCloseAsyncIterator(error1); }
			}, ifAbruptCloseAsyncIterator);
			} catch (error) { ifAbruptCloseAsyncIterator(error); }
			} else outerLoop();
			};

			innerLoop();
			});
			});

			// `AsyncIterator.prototype.flaMap` method
			// https://github.com/tc39/proposal-iterator-helpers
			$({ target: 'AsyncIterator', proto: true, real: true }, {
			flatMap: function flatMap(mapper) {
			return new AsyncIteratorProxy(getIteratorDirect(this), {
			mapper: aCallable(mapper),
			inner: null
			});
			}
			});