Administrator
13 hours ago 9703dcd75b910e4a98cd2c44aa7dda74a6fe8586
src/main/java/com/xcong/excoin/modules/gateApi/GateKlineWebSocketClient.java
@@ -258,6 +258,12 @@
            }
            if ("subscribe".equals(event)) {
                log.info("[WS] {} 订阅成功: {}", channel, response.getJSONObject("result"));
                for (GateChannelHandler handler : channelHandlers) {
                    if (channel.equals(handler.getChannelName())) {
                        handler.setSubscribed(true);
                        break;
                    }
                }
                return;
            }
            if ("unsubscribe".equals(event)) {
@@ -282,6 +288,17 @@
        }
    }
    /**
     * 检查所有已注册的频道是否都已收到订阅成功确认。
     */
    public boolean areAllSubscribed() {
        if (channelHandlers.isEmpty()) return false;
        for (GateChannelHandler h : channelHandlers) {
            if (!h.isSubscribed()) return false;
        }
        return true;
    }
    // ---- heartbeat ----
    /**