mirror/openscale
1
0
Fork 0
mirror of https://github.com/oliexdev/openScale.git synced 2025-08-17 22:11:35 +02:00
Code Issues Releases Wiki Activity

adding a delay of 500 ms between the end of the BLE scan and the beginning of a connection

Browse Source
This commit is contained in:
oliexdev
2019-02-10 21:31:34 +01:00
parent 60d6818520
commit 1617315472
1 changed files with 24 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

41
android_app/app/src/main/java/com/health/openscale/core/bluetooth/BluetoothCommunication.java
View File

@@ -517,28 +517,35 @@ public abstract class BluetoothCommunication {
Timber.d("Stop Le san");
scanSubscription.dispose();
scanSubscription = null;
}
Timber.d("Try to connect to BLE device " + macAddress);
Handler handler = new Handler();
handler.postDelayed(new Runnable() {
@Override
public void run() {
Timber.d("Try to connect to BLE device " + macAddress);
connectionObservable = bleDevice
.establishConnection(false)
.delay(BT_DELAY, TimeUnit.MILLISECONDS)
.takeUntil(disconnectTriggerSubject)
.doOnError(throwable -> setBtStatus(BT_STATUS_CODE.BT_CONNECTION_RETRYING))
.observeOn(AndroidSchedulers.mainThread())
.compose(ReplayingShare.instance());
connectionObservable = bleDevice
.establishConnection(false)
.delay(BT_DELAY, TimeUnit.MILLISECONDS)
.takeUntil(disconnectTriggerSubject)
.doOnError(throwable -> setBtStatus(BT_STATUS_CODE.BT_CONNECTION_RETRYING))
.observeOn(AndroidSchedulers.mainThread())
.compose(ReplayingShare.instance());
if (isConnected()) {
disconnect();
} else {
initStepNr = -1;
cmdStepNr = -1;
cleanupStepNr = -1;
if (isConnected()) {
disconnect();
} else {
initStepNr = -1;
cmdStepNr = -1;
cleanupStepNr = -1;
setBtMonitoringOn();
setBtMachineState(BT_MACHINE_STATE.BT_INIT_STATE);
}
setBtMonitoringOn();
setBtMachineState(BT_MACHINE_STATE.BT_INIT_STATE);
}
}
}, 500);
}
private void setBtMonitoringOn() {