How to upload with limit concurrency connections

upload.ts

/**
 * Uploads artifacts with a set concurrency limit.
 */
async function uploadWithConcurrency(
  artifacts: BunnyArtifact[],
  concurrency: number,
  task: (artifact: BunnyArtifact) => Promise<void>
): Promise<void> {
  const queue: Promise<void>[] = []
  for (const artifact of artifacts) {
    const taskPromise = task(artifact)
    queue.push(taskPromise)

    // Await if queue exceeds concurrency
    if (queue.length >= concurrency) {
      await Promise.race(queue)
      // Remove the completed items
      queue.splice(
        queue.findIndex((p) => p === taskPromise),
        1
      )
    }
  }

  await Promise.all(queue) // Wait for remaining uploads
}