Can't re-establish connection about rxandroidble HOT 9 CLOSED

So this is what I have to automatically try to connect to device after disconnect happens with 5 seconds delay:

rxBleDevice.establishConnection(context, false) // <-- autoConnect flag
    .doOnError(throwable -> {
        Log.d(TAG, "rxBleConnection doOnError: " + throwable);
    })
    .retryWhen(new Func1<Observable<? extends Throwable>, Observable<?>>() {
        @Override
        public Observable<?> call(Observable<? extends Throwable> errorNotification) {
            return errorNotification
                    .flatMap(new Func1<Throwable, Observable<?>>() {
                        @Override
                        public Observable<?> call(Throwable throwable) {
                            Log.v(TAG, "connect retrying...");
                            return Observable.timer(5, TimeUnit.SECONDS);
                        }
                    });
        }
    })
    .subscribe(rxBleConnection -> {
        Log.d(TAG, "rxBleConnection: " + rxBleConnection);
    });

from rxandroidble.

This is expected behavior. Once disconnected you need to establish the connection manually again. Why do you think that it should be anyway different?

from rxandroidble.

The library notifies you that the connection has been lost but you need to call establish connection again to reconnect. Is that the case?

from rxandroidble.

yes

from rxandroidble.

Sorry, misunderstood you.
I just call this code again when connection state change(disconnected) appear.
and nothing happened.

from rxandroidble.

Could you provide code sample and preferably logs from RxAndroidBle?

from rxandroidble.

Please look at sources: https://github.com/dlykoits/RxAndtoidBLESample.git
Steps to reproduce:

1. press connect -> ble device connected
2. then turn off ble device - > connection lost
3. turn on ble device
4. press connect
   Actual result:
   connection establishment doesn't work, "disconnected" status appear immediately after establish call
   Expected result:
   connection established again

from rxandroidble.

What I see is that you're trying to reuse a Subscriber here and that is a misuse as the Subscriber is stateful and therefore cannot be reused. It was already failed once and is probably unsubscribing automatically.
You can try either to create a new Subscriber for each subscription or to use an Observer instead - which is stateless.

from rxandroidble.

You right, Thanks a lot!!!
P.S.: I started learning RX week ago.

from rxandroidble.