Atlas48/grungnet
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Clear socket buffer on reconnect

Browse Source
This commit is contained in:
Nicola Thouliss 2021-10-21 18:35:16 +11:00
parent c359d3f319
commit e928541370
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/network/Session.ts
View File

@ -88,7 +88,7 @@ class Session extends EventEmitter {
this.socket.on("force_update", this._handleForceUpdate.bind(this)); this.socket.on("force_update", this._handleForceUpdate.bind(this));
this.emit("status", "ready"); this.emit("status", "ready");
} catch (error) { } catch (error: any) {
logError(error); logError(error);
this.emit("status", "offline"); this.emit("status", "offline");
} }
@ -302,7 +302,7 @@ class Session extends EventEmitter {
this.peers[id] = peer; this.peers[id] = peer;
return true; return true;
} catch (error) { } catch (error: any) {
logError(error); logError(error);
this.emit("peerError", { error }); this.emit("peerError", { error });
for (let peer of Object.values(this.peers)) { for (let peer of Object.values(this.peers)) {
@ -360,6 +360,7 @@ class Session extends EventEmitter {
} }
_handleSocketReconnect() { _handleSocketReconnect() {
this.socket.sendBuffer = [];
if (this._gameId) { if (this._gameId) {
this.joinGame(this._gameId, this._password); this.joinGame(this._gameId, this._password);
} }