regenerate dist

Signed-off-by: Meredith Lancaster <malancas@github.com>

dist/606.index.js

@@ -1,7 +1,6 @@
-"use strict";
-exports.id = 606;
-exports.ids = [606];
-exports.modules = {
+export const id = 606;
+export const ids = [606];
+export const modules = {
 
 /***/ 606:
 /***/ ((__unused_webpack___webpack_module__, __webpack_exports__, __webpack_require__) => {
@@ -19,7 +18,7 @@ async function pMap(
 		signal,
 	} = {},
 ) {
-	return new Promise((resolve_, reject_) => {
+	return new Promise((resolve, reject_) => {
 		if (iterable[Symbol.iterator] === undefined && iterable[Symbol.asyncIterator] === undefined) {
 			throw new TypeError(`Expected \`input\` to be either an \`Iterable\` or \`AsyncIterable\`, got (${typeof iterable})`);
 		}
@@ -42,24 +41,10 @@ async function pMap(
 		let currentIndex = 0;
 		const iterator = iterable[Symbol.iterator] === undefined ? iterable[Symbol.asyncIterator]() : iterable[Symbol.iterator]();
 
-		const signalListener = () => {
-			reject(signal.reason);
-		};
-
-		const cleanup = () => {
-			signal?.removeEventListener('abort', signalListener);
-		};
-
-		const resolve = value => {
-			resolve_(value);
-			cleanup();
-		};
-
 		const reject = reason => {
 			isRejected = true;
 			isResolved = true;
 			reject_(reason);
-			cleanup();
 		};
 
 		if (signal) {
@@ -67,7 +52,9 @@ async function pMap(
 				reject(signal.reason);
 			}
 
-			signal.addEventListener('abort', signalListener, {once: true});
+			signal.addEventListener('abort', () => {
+				reject(signal.reason);
+			});
 		}
 
 		const next = async () => {
@@ -215,32 +202,31 @@ function pMapIterable(
 			const iterator = iterable[Symbol.asyncIterator] === undefined ? iterable[Symbol.iterator]() : iterable[Symbol.asyncIterator]();
 
 			const promises = [];
-			let pendingPromisesCount = 0;
+			let runningMappersCount = 0;
 			let isDone = false;
 			let index = 0;
 
 			function trySpawn() {
-				if (isDone || !(pendingPromisesCount < concurrency && promises.length < backpressure)) {
+				if (isDone || !(runningMappersCount < concurrency && promises.length < backpressure)) {
 					return;
 				}
 
-				pendingPromisesCount++;
-
 				const promise = (async () => {
 					const {done, value} = await iterator.next();
 
 					if (done) {
-						pendingPromisesCount--;
 						return {done: true};
 					}
 
+					runningMappersCount++;
+
 					// Spawn if still below concurrency and backpressure limit
 					trySpawn();
 
 					try {
 						const returnValue = await mapper(await value, index++);
 
-						pendingPromisesCount--;
+						runningMappersCount--;
 
 						if (returnValue === pMapSkip) {
 							const index = promises.indexOf(promise);
@@ -255,7 +241,6 @@ function pMapIterable(
 
 						return {done: false, value: returnValue};
 					} catch (error) {
-						pendingPromisesCount--;
 						isDone = true;
 						return {error};
 					}
@@ -298,4 +283,3 @@ const pMapSkip = Symbol('skip');
 /***/ })
 
 };
-;

dist/package.json

@@ -0,0 +1,3 @@
+{
+  "type": "module"
+}