如何检查RxBleConnection的状态

import com.polidea.rxandroidble2.RxBleConnection;
import com.polidea.rxandroidble2.exceptions.BleDisconnectedException;
import com.polidea.rxandroidble2.exceptions.BleException;
import io.reactivex.disposables.Disposable;
import io.reactivex.functions.Consumer;

RxBleConnection rxBleConnection = ...; // 获取RxBleConnection对象的方式，例如通过扫描和连接BLE设备

Disposable connectionDisposable = rxBleConnection
        .stateChanges()
        .subscribe(new Consumer<RxBleConnection.RxBleConnectionState>() {
            @Override
            public void accept(RxBleConnection.RxBleConnectionState state) throws Exception {
                // 在这里处理连接状态的变化
                switch (state) {
                    case CONNECTING:
                        // 正在连接
                        break;
                    case CONNECTED:
                        // 已连接
                        break;
                    case DISCONNECTED:
                        // 已断开连接
                        break;
                    case DISCONNECTING:
                        // 正在断开连接
                        break;
                }
            }
        }, new Consumer<Throwable>() {
            @Override
            public void accept(Throwable throwable) throws Exception {
                // 处理连接状态变化时的错误
                if (throwable instanceof BleDisconnectedException) {
                    // 设备已断开连接
                } else if (throwable instanceof BleException) {
                    // 其他BLE异常
                }
            }
        });

connectionDisposable.dispose();