| 35923 | |
| 35924 | class BlockingQueue { |
| 35925 | constructor(alias, maxConcurrency = Infinity) { |
| 35926 | this.concurrencyQueue = []; |
| 35927 | this.maxConcurrency = maxConcurrency; |
| 35928 | this.runningCount = 0; |
| 35929 | this.warnedStuck = false; |
| 35930 | this.alias = alias; |
| 35931 | this.first = true; |
| 35932 | |
| 35933 | this.running = (0, (_map || _load_map()).default)(); |
| 35934 | this.queue = (0, (_map || _load_map()).default)(); |
| 35935 | |
| 35936 | this.stuckTick = this.stuckTick.bind(this); |
| 35937 | } |
| 35938 | |
| 35939 | stillActive() { |
| 35940 | if (this.stuckTimer) { |