问题描述
我正在使用 RXAndroidBle 库从 BLE 设备连接和读取数据。我已将 establishConnection 函数设置为 true，即自动连接为 true。当 BleAlreadyConnectedException 发生时，我想捕获该异常并重新启动读取数据流，因为每次处理和连接到 BLE 设备时都会产生问题。所以最好保持连接并重新读取数据。
在 onErrorResumeNext 中，我重新调用函数 writeStatus、readModelInfo、getReadings 等。现在确定我将如何实现它。
device.establishConnection(true)
.flatMap(rxBleConnection -> {
rxBleConnection.discoverServices();
mRxBleConnection = rxBleConnection;
return Observable.just(rxBleConnection);
})
.flatMap(rxBleConnection -> rxBleConnection.setupNotification(TSDictionary.BATTERY_LEVEL,NotificationSetupMode.QUICK_SETUP).flatMap(it->it))
.flatMap(bytes -> writeStatus())
.flatMap(bytes->readModelInfo(bytes))
.flatMap(bytes -> getReadings(bytes))
.doOnNext(data->initializeErrorHistory(data))
.flatMap(data->getSequenceSize())
.flatMap(length ->getoperationInfo(length))
.doOnNext(data->initializeOperationInfo(data))
.onErrorResumeNext(new Function<Throwable,ObservableSource<? extends ArrayList<Map<Integer,TSDictionaryMetaData>>>>() {
@Override
public ObservableSource<? extends ArrayList<Map<Integer,TSDictionaryMetaData>>> apply(@io.reactivex.annotations.NonNull Throwable throwable) throws Exception {
if(throwable instanceof BleAlreadyConnectedException){
// i want to RECALL/restart the function call
// writeStatus,readModelInfo,getReadings,initializeErrorHistory
// getSequenceSize,getoperationInfo,initializeOperationInfo
}
return null;
}
})
.subscribe(data -> {
},e -> {
e.printstacktrace();
});
解决方法
将 onErrorResumeNext 靠近连接代码。
device.establishConnection(true)
.doOnNext(rxBleConnection -> {
rxBleConnection.discoverServices();
mRxBleConnection = rxBleConnection;
})
.onErrorResumeNext(throwable -> {
if (throwable instanceof BleAlreadyConnectedException) {
return Observable.just(mRxBleConnection);
}
return Observable.error(throwable);
})
.flatMap(rxBleConnection ->
rxBleConnection.setupNotification(TSDictionary.BATTERY_LEVEL,NotificationSetupMode.QUICK_SETUP)
.flatMap(it->it)
)
.flatMap(bytes -> writeStatus())
.flatMap(bytes->readModelInfo(bytes))
.flatMap(bytes -> getReadings(bytes))
.doOnNext(data->initializeErrorHistory(data))
.flatMap(data->getSequenceSize())
.flatMap(length ->getOperationInfo(length))
.doOnNext(data->initializeOperationInfo(data))
.subscribe(data -> {
},e -> {
e.printStackTrace();
});