aboutsummaryrefslogtreecommitdiff
path: root/sandbox/testAppNevena/Front/node_modules/p-map/index.js
diff options
context:
space:
mode:
authorNevena Bojovic <nenabojov@gmail.com>2022-03-01 22:05:25 +0100
committerNevena Bojovic <nenabojov@gmail.com>2022-03-01 22:05:25 +0100
commit6555fb80fdd8f6a5d201efadec3189d1244830a0 (patch)
treec1aa1c5aedc634ad1ea7fad4847884d559b51290 /sandbox/testAppNevena/Front/node_modules/p-map/index.js
parent7d3640f824f46490b47bd95f1c5a16644f712068 (diff)
Izbrisala bin, obj i node-modules.
Diffstat (limited to 'sandbox/testAppNevena/Front/node_modules/p-map/index.js')
-rw-r--r--sandbox/testAppNevena/Front/node_modules/p-map/index.js81
1 files changed, 0 insertions, 81 deletions
diff --git a/sandbox/testAppNevena/Front/node_modules/p-map/index.js b/sandbox/testAppNevena/Front/node_modules/p-map/index.js
deleted file mode 100644
index c11a2851..00000000
--- a/sandbox/testAppNevena/Front/node_modules/p-map/index.js
+++ /dev/null
@@ -1,81 +0,0 @@
-'use strict';
-const AggregateError = require('aggregate-error');
-
-module.exports = async (
- iterable,
- mapper,
- {
- concurrency = Infinity,
- stopOnError = true
- } = {}
-) => {
- return new Promise((resolve, reject) => {
- if (typeof mapper !== 'function') {
- throw new TypeError('Mapper function is required');
- }
-
- if (!((Number.isSafeInteger(concurrency) || concurrency === Infinity) && concurrency >= 1)) {
- throw new TypeError(`Expected \`concurrency\` to be an integer from 1 and up or \`Infinity\`, got \`${concurrency}\` (${typeof concurrency})`);
- }
-
- const result = [];
- const errors = [];
- const iterator = iterable[Symbol.iterator]();
- let isRejected = false;
- let isIterableDone = false;
- let resolvingCount = 0;
- let currentIndex = 0;
-
- const next = () => {
- if (isRejected) {
- return;
- }
-
- const nextItem = iterator.next();
- const index = currentIndex;
- currentIndex++;
-
- if (nextItem.done) {
- isIterableDone = true;
-
- if (resolvingCount === 0) {
- if (!stopOnError && errors.length !== 0) {
- reject(new AggregateError(errors));
- } else {
- resolve(result);
- }
- }
-
- return;
- }
-
- resolvingCount++;
-
- (async () => {
- try {
- const element = await nextItem.value;
- result[index] = await mapper(element, index);
- resolvingCount--;
- next();
- } catch (error) {
- if (stopOnError) {
- isRejected = true;
- reject(error);
- } else {
- errors.push(error);
- resolvingCount--;
- next();
- }
- }
- })();
- };
-
- for (let i = 0; i < concurrency; i++) {
- next();
-
- if (isIterableDone) {
- break;
- }
- }
- });
-};