Handler for raw message.
(event: MessageEvent)
| 169 | |
| 170 | /** Handler for raw message. */ |
| 171 | private onMessage(event: MessageEvent): void { |
| 172 | const buffer = event.data; |
| 173 | this.buffredBytes += buffer.byteLength; |
| 174 | this.messageQueue.push(new Uint8Array(buffer)); |
| 175 | this.processEvents(); |
| 176 | } |
| 177 | /** Process ready events. */ |
| 178 | private processEvents(): void { |
| 179 | while (this.buffredBytes >= this.pendingBytes && this.pendingBytes != 0) { |
no test coverage detected