/*
 * © Copyright 2022 HP Development Company, L.P.
 * SPDX-License-Identifier: MIT
 */

type Iterable<T, ReturnType> = (item: T, index: number) => Promise<ReturnType> | ReturnType;

export async function mapSeries<T = unknown, ReturnType = unknown>(
	data: T[],
	fn: Iterable<T, ReturnType>
): Promise<ReturnType[]> {
	const results = [];
	for (let index = 0; index < data.length; index++) {
		const item = data[index];
		// eslint-disable-next-line
		results.push(await fn(item, index));
	}

	return results;
}

export async function mapParallel<T = unknown, ReturnType = unknown>(
	data: T[],
	fn: Iterable<T, ReturnType>
): Promise<ReturnType[]> {
	return Promise.all(data.map((item, index) => fn(item, index)));
}

export async function nextTick<FN extends (...args: Array<unknown>) => any>(fn?: FN): Promise<ReturnType<FN>> {
	return new Promise((resolve, reject) => {
		process.nextTick(async () => {
			try {
				resolve(await fn?.());
			} catch (err) {
				reject(err);
			}
		});
	});
}