Function worker

src/shared/pub/utils.ts:40–59

()

	/// A worker that continuously processes items until there are none left.
	const worker = async () => {
		while (!firstError && !cancellationToken.isCancellationRequested) {
			// Grab the index of the next item.
			const index = nextIndex++;
			if (index >= items.length)
				return; // All items are done.

			const item = items[index];
			onStarted?.(item); // Signal that we're starting.

			try {
				await task(item); // Run the main task.
				completed++;
				onCompleted?.(completed, items.length, item);  // Signal that we're done.
			} catch (error) {
				firstError ??= error;
				return;
			}
		}
	};

	await Promise.all(Array.from({ length: maxWorkers }, () => worker()));