[WeBsocket] - Opening a new one after close old wsocket;

Author: aLexandreM1

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>io.github.grinply</groupId>
     <artifactId>bybit-java-api</artifactId>
-    <version>1.0.7</version>
+    <version>1.0.8</version>
     <name>bybit-java-api</name>
     <packaging>jar</packaging>
     <url>https://github.com/grinply/bybit-java-api</url>

src/main/java/com/grinply/api/client/websocket/impl/WebsocketStreamClientImpl.java

@@ -233,7 +233,7 @@ public void onFailure(@NotNull WebSocket webSocket, @NotNull Throwable t, @Nulla
                     LOGGER.error("Trying to open a new connection in same wsocket: ", t);
                     WebsocketStreamClientImpl.this.onClose(webSocket, 0, "Socket Exception caused by server");
                 }
-                reconnect();
+                connect();
             }
 
             @Override
@@ -293,7 +293,8 @@ public void onError(WebSocket webSocket, Throwable t) {
     @Override
     public void onClose(WebSocket ws, int code, String reason) {
         LOGGER.info("WebSocket closed. Code: {}, Reason: {}", code, reason);
-        ws.close(code, reason);
+        // cancel, since we're having problems using close (it's wait for graceful shutdown)
+        ws.cancel();
         this.webSocket = null;
     }
 
@@ -327,27 +328,6 @@ public WebSocket connect() {
         return this.webSocket;
     }
 
-    private synchronized void reconnect() {
-        try {
-            // Reconnect to the same stream
-            if (requiresAuthentication(path)) {
-                if (path.equals(BybitApiConfig.V5_TRADE) && params != null) {
-                    getTradeChannelStream(params, path);
-                } else if (argNames != null) {
-                    getPrivateChannelStream(argNames, path);
-                }
-            } else {
-                if (argNames != null) {
-                    getPublicChannelStream(argNames, path);
-                } else {
-                    LOGGER.warn("No args provided for public stream. Cannot reconnect.");
-                }
-            }
-        } catch (Exception e) {
-            LOGGER.error("Reconnect failed", e);
-        }
-    }
-
     @Override
     public WebSocket getPublicChannelStream(List<String> argNames, String path) {
         setupChannelStream(argNames, path);