Spaces:

Leon4gr45
/

nova-header-nav

Paused

nova-header-nav / node_modules /@huggingface /hub /src /utils /promisesQueue.ts

Upload folder using huggingface_hub (part 5)

01e6679 verified 4 months ago

602 Bytes

/**
 * Execute queue of promises.
 *
 * Inspired by github.com/rxaviers/async-pool
 */
export async function promisesQueue<T>(factories: (() => Promise<T>)[], concurrency: number): Promise<T[]> {
	const results: T[] = [];
	const executing: Set<Promise<void>> = new Set();
	let index = 0;
	for (const factory of factories) {
		const closureIndex = index++;
		const e = factory().then((r) => {
			results[closureIndex] = r;
			executing.delete(e);
		});
		executing.add(e);
		if (executing.size >= concurrency) {
			await Promise.race(executing);
		}
	}
	await Promise.all(executing);
	return results;
}

	/**
	* Execute queue of promises.
	*
	* Inspired by github.com/rxaviers/async-pool
	*/
	export async function promisesQueue<T>(factories: (() => Promise<T>)[], concurrency: number): Promise<T[]> {
	const results: T[] = [];
	const executing: Set<Promise<void>> = new Set();
	let index = 0;
	for (const factory of factories) {
	const closureIndex = index++;
	const e = factory().then((r) => {
	results[closureIndex] = r;
	executing.delete(e);
	});
	executing.add(e);
	if (executing.size >= concurrency) {
	await Promise.race(executing);
	}
	}
	await Promise.all(executing);
	return results;
	}