* Emit buffered events (received and emitted). * * @private
()
| 843 | * @private |
| 844 | */ |
| 845 | private emitBuffered(): void { |
| 846 | this.receiveBuffer.forEach((args) => this.emitEvent(args)); |
| 847 | this.receiveBuffer = []; |
| 848 | |
| 849 | this.sendBuffer.forEach((packet) => { |
| 850 | this.notifyOutgoingListeners(packet); |
| 851 | this.packet(packet); |
| 852 | }); |
| 853 | this.sendBuffer = []; |
| 854 | } |
| 855 | |
| 856 | /** |
| 857 | * Called upon server disconnect. |
no test coverage detected