dev (#183)

pom.xml

@@ -151,7 +151,7 @@
     <properties>
         <scx.mainClass>cool.scx.live_room_watcher.Main</scx.mainClass>
 
-        <scx.version>2.7.1</scx.version>
+        <scx.version>2.7.2</scx.version>
         <protobuf.version>3.25.3</protobuf.version>
         <jsoup.version>1.17.2</jsoup.version>
         <graalvm-js.version>23.0.3</graalvm-js.version>

src/main/java/cool/scx/live_room_watcher/impl/_560game/_560GameWatchTask.java

@@ -4,7 +4,7 @@
 import com.fasterxml.jackson.databind.node.ObjectNode;
 import cool.scx.util.ObjectUtils;
 import cool.scx.util.ScxExceptionHelper;
-import cool.scx.util.ScxFuture;
+import cool.scx.util.SingleListenerFuture;
 import io.netty.util.Timeout;
 import io.vertx.core.http.WebSocket;
 import io.vertx.core.http.WebSocketConnectOptions;
@@ -25,7 +25,7 @@ public class _560GameWatchTask {
     private final String username;
     private final String password;
     private final _560GameLiveRoomWatcher watcher;
-    private ScxFuture<WebSocket> webSocketFuture;
+    private SingleListenerFuture<WebSocket> webSocketFuture;
     private WebSocket webSocket;
 
     private Timeout ping;
@@ -44,7 +44,7 @@ public void start() {
         var s = watcher.validateUser(this.username, this.password);
         var ws_url = getWsUrl(s, username);
         logger.log(DEBUG,"连接开始 地址"+ws_url);
-        this.webSocketFuture = new ScxFuture<>(watcher.webSocketClient.connect(new WebSocketConnectOptions().setAbsoluteURI(ws_url)));
+        this.webSocketFuture = new SingleListenerFuture<>(watcher.webSocketClient.connect(new WebSocketConnectOptions().setAbsoluteURI(ws_url)));
 
         webSocketFuture.onSuccess(ws -> {
             webSocket = ws;