(id: number, wait?: Promise<void>)
| 67 | let releaseQueued: (() => void) | undefined; |
| 68 | |
| 69 | const run = async (id: number, wait?: Promise<void>) => { |
| 70 | await sem.acquire(); |
| 71 | concurrent++; |
| 72 | maxConcurrent = Math.max(maxConcurrent, concurrent); |
| 73 | order.push(id); |
| 74 | await wait; |
| 75 | concurrent--; |
| 76 | sem.release(); |
| 77 | }; |
| 78 | |
| 79 | await sem.acquire(); |
| 80 | concurrent++; |
no test coverage detected