fix: reset ping tracker on websocket close (#602)

twitch4j · Jul 17, 2022 · d119698 · d119698
1 parent 9d094e6
commit d119698
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/client-websocket/src/main/java/com/github/twitch4j/client/websocket/WebsocketConnection.java b/client-websocket/src/main/java/com/github/twitch4j/client/websocket/WebsocketConnection.java
@@ -283,11 +283,16 @@ public void close() throws Exception {
 
     @Synchronized
     private void closeSocket() {
+        // Clean up the socket
         if (webSocket != null) {
             this.webSocket.disconnect();
             this.webSocket.clearListeners();
             this.webSocket = null;
         }
+
+        // Reset latency tracker
+        this.latency = -1L;
+        lastPing.lazySet(0L);
     }
 
 }