(maxConcurrent: number = 5)
| 21 | private results = new Map<string, TaskResult>(); |
| 22 | |
| 23 | constructor(maxConcurrent: number = 5) { |
| 24 | this.maxConcurrent = maxConcurrent; |
| 25 | } |
| 26 | |
| 27 | async execute<T>(tasks: Task<T>[]): Promise<TaskResult<T>[]> { |
| 28 | // Add tasks to queue |
nothing calls this directly
no outgoing calls
no test coverage detected