Add support for multiple pMapSkip's

index.js

@@ -62,6 +62,9 @@ export default async function pMap(
 					} else {
 						isResolved = true;
 
+						// Delete skipped index from back to front, to support multiple pMapSkips
+						// so use the unshift method when putting index into skippedIndexes.
+						// see line 93
 						for (const skippedIndex of skippedIndexes) {
 							result.splice(skippedIndex, 1);
 						}
@@ -87,7 +90,7 @@ export default async function pMap(
 					const value = await mapper(element, index);
 
 					if (value === pMapSkip) {
-						skippedIndexes.push(index);
+						skippedIndexes.unshift(index);
 					} else {
 						result[index] = value;
 					}

test.js

@@ -155,6 +155,19 @@ test('pMapSkip', async t => {
 	], async value => value), [1, 2]);
 });
 
+test('multiple pMapSkips', async t => {
+	t.deepEqual(await pMap([
+		1,
+		pMapSkip,
+		2,
+		pMapSkip,
+		3,
+		pMapSkip,
+		pMapSkip,
+		4
+	], async value => value), [1, 2, 3, 4]);
+});
+
 test('all mappers should run when concurrency is infinite, even after stop-on-error happened', async t => {
 	const input = [1, async () => delay(300, {value: 2}), 3];
 	const mappedValues = [];
@@ -269,6 +282,19 @@ test('asyncIterator - pMapSkip', async t => {
 	]), async value => value), [1, 2]);
 });
 
+test('asyncIterator - multiple pMapSkips', async t => {
+	t.deepEqual(await pMap(new AsyncTestData([
+		1,
+		pMapSkip,
+		2,
+		pMapSkip,
+		3,
+		pMapSkip,
+		pMapSkip,
+		4
+	]), async value => value), [1, 2, 3, 4]);
+});
+
 test('asyncIterator - all mappers should run when concurrency is infinite, even after stop-on-error happened', async t => {
 	const input = [1, async () => delay(300, {value: 2}), 3];
 	const mappedValues = [];