()
| 239 | } |
| 240 | |
| 241 | private async waitForAnyExecution(): Promise<void> { |
| 242 | if (this.executing.size > 0) { |
| 243 | await Promise.race([...this.executing, this.abortPromise]) |
| 244 | } |
| 245 | } |
| 246 | |
| 247 | private async waitForAllExecutions(): Promise<void> { |
| 248 | await Promise.race([Promise.all(this.executing), this.abortPromise]) |