* Process queue - send messages in ID order that are released
()
| 136 | * Process queue - send messages in ID order that are released |
| 137 | */ |
| 138 | private async processQueue(): Promise<void> { |
| 139 | await this.lock.inLock(async () => { |
| 140 | this.processQueueInternal(); |
| 141 | }); |
| 142 | } |
| 143 | |
| 144 | /** |
| 145 | * Flush all messages immediately (for cleanup) |
no test coverage detected