diff --git a/android/src/main/java/com/bleplx/adapter/BleModule.java b/android/src/main/java/com/bleplx/adapter/BleModule.java index 0fbed672..2bae763e 100755 --- a/android/src/main/java/com/bleplx/adapter/BleModule.java +++ b/android/src/main/java/com/bleplx/adapter/BleModule.java @@ -1267,7 +1267,10 @@ private void safeConnectToDevice(final RxBleDevice device, } if (timeout != null) { - connect = connect.timeout(timeout, TimeUnit.MILLISECONDS); + connect = connect.timeout( + Observable.timer(timeout, TimeUnit.MILLISECONDS), + item -> Observable.never() + ); }