Method close

java/lib/src/main/java/io/github/ccxt/ws/WsClient.java:590–622

Close the WebSocket connection and reject all pending futures.

()

     * Close the WebSocket connection and reject all pending futures.
     */
    public void close() {
        if (this.verbose) {
            System.out.println("WsClient closing: " + this.url);
        }
        if (this.channel != null && this.channel.isActive()) {
            this.channel.writeAndFlush(new CloseWebSocketFrame());
        }
        this.isConnected = false;
        this.startedConnecting.set(false);

        // Wake the ping loop so it exits without waiting for the next keepAlive tick.
        Thread pt = this.pingThread;
        if (pt != null) {
            pt.interrupt();
        }

        // Snapshot keys before mutating the map to avoid ConcurrentModificationException.
        // Prefer the typed closeReason (set by Exchange.close()) over a bare
        // RuntimeException, so consumers can `catch (ExchangeClosedByUser)` and
        // tell deliberate shutdown from a remote-side disconnect.
        Throwable rejectionReason = (this.closeReason != null)
                ? this.closeReason
                : new io.github.ccxt.errors.ExchangeClosedByUser("Connection closed by the user");
        var snapshot = new java.util.ArrayList<>(futuresMap().keySet());
        for (String key : snapshot) {
            Future f = futuresMap().remove(key);
            if (f != null && !f.isDone()) {
                f.reject(rejectionReason);
            }
        }

        messageExecutor.shutdown();
    }

    // ─── Binary decompression (matches C# lines 393-471) ───
    // Note: Netty handles WebSocket frame aggregation before our handler sees frames,