小编Jog*_*osb的帖子

我正在创建一个简单的应用程序，用于使用RxAndroidBle库与蓝牙设备进行连接（干得好！）。我有时遇到的情况是，当我连接到设备时，收到状态为133的Gatt错误。我知道它可能会发生，所以我想做的就是在发生该错误时重试所有内容。没问题，我可以使用retryWhen()运算符轻松地做到这一点，但是我还有另一个要求-如果连接失败，流必须在30秒后终止。我曾经timeout()这样做，但是问题是当我重试时，计时器再次启动。

因此，问题是如何将timeout（）运算符与retryWhen（）结合使用，以便我可以重试某些特定错误，但保持计数器继续运行。

我对合并可观察变量有一些想法，或者有一些单独的可观察变量，它们将在超时期限后检查连接状态，但是我想知道是否可以在单个可观察变量中进行此操作。

到目前为止，我的代码如下所示：

public Observable<ConnectingViewState> connectToDevice(String macAddress) {
        final RxBleDevice rxBleDevice = rxBleClient.getBleDevice(macAddress);
        return rxBleDevice.establishConnection(false)
                .subscribeOn(Schedulers.io())
                .map(rxBleConnection -> new ConnectingViewState.ConnectedViewState(rxBleConnection))
                .cast(ConnectingViewState.class)
                .timeout(40, TimeUnit.SECONDS)
                .startWith(new ConnectingViewState.ConnectingInProgressViewState())
                .retryWhen(errors -> errors.flatMap(error -> {
                            if (isDefaultGattError(error)) {
                                return Observable.just(new Object());
                            } else {
                                return Observable.error(error);
                            }
                        }
                ))
                .onErrorReturn(throwable -> new ConnectingViewState.ErrorState(throwable));
    }