(alias, maxConcurrency = Infinity)
| 35489 | |
| 35490 | class BlockingQueue { |
| 35491 | constructor(alias, maxConcurrency = Infinity) { |
| 35492 | this.concurrencyQueue = []; |
| 35493 | this.maxConcurrency = maxConcurrency; |
| 35494 | this.runningCount = 0; |
| 35495 | this.warnedStuck = false; |
| 35496 | this.alias = alias; |
| 35497 | this.first = true; |
| 35498 | |
| 35499 | this.running = (0, (_map || _load_map()).default)(); |
| 35500 | this.queue = (0, (_map || _load_map()).default)(); |
| 35501 | |
| 35502 | this.stuckTick = this.stuckTick.bind(this); |
| 35503 | } |
| 35504 | |
| 35505 | stillActive() { |
| 35506 | if (this.stuckTimer) { |
nothing calls this directly
no test coverage detected