()
| 283 | const workers: Promise<void>[] = [] |
| 284 | |
| 285 | async function worker() { |
| 286 | while (taskQueue.length > 0) { |
| 287 | const task = taskQueue.shift() |
| 288 | if (task) { |
| 289 | await runTask(task) |
| 290 | } |
| 291 | } |
| 292 | } |
| 293 | |
| 294 | // Start workers |
| 295 | for (let i = 0; i < Math.min(concurrency, tasks.length); i++) { |
no test coverage detected