rxjava2 手动关闭不成功 about rxwebsocket HOT 6 CLOSED

    private WebSocketSubscriber webSocketSubscriber;

    public void openWebSocket() {
        webSocketSubscriber = new WebSocketSubscriber() {
            @Override
            protected void onMessage(String text) {

            }

            @Override
            protected void onReconnect() {
                Log.d("MainActivity", "重连");
            }
        };
        RxWebSocket.get("your url")
                .subscribe(webSocketSubscriber);
    }

    public void closeWebSocket() {
        if (webSocketSubscriber != null) {
            webSocketSubscriber.dispose();
        }
    }

    private Disposable mDisposable;

    public void openWebSocket() {
        mDisposable = RxWebSocket.get("your url");
                .subscribe(new WebSocketSubscriber() {
            @Override
            protected void onMessage(String text) {

            }

            @Override
            protected void onReconnect() {
                Log.d("MainActivity", "重连");
            }
        });
    }

    public void  closeWebSocket() {
        if (mDisposable != null) {
            mDisposable.dispose();
        }
    }