Fixed issue that sometimes happened where RxBleRadioOperationConnect …

…was not yet subscribed while running. #94

Reviewers: michal.zielinski, pawel.urban

Reviewed By: pawel.urban

Differential Revision: https://phabricator.polidea.com/D1947

rxandroidble/src/main/java/com/polidea/rxandroidble/internal/operations/RxBleRadioOperationConnect.java

@@ -25,7 +25,7 @@ public class RxBleRadioOperationConnect extends RxBleRadioOperation<BluetoothGat
     private final Runnable releaseRadioRunnable = () -> releaseRadio();
     private final Runnable emptyRunnable = () -> {
     };
-    private final BehaviorSubject<Boolean> isSubscribed = BehaviorSubject.create(false);
+    private final BehaviorSubject<Boolean> isSubscribed = BehaviorSubject.create();
     private final Observable<BluetoothGatt> operationConnectAsObservableWithSubscribersMonitoring = super.asObservable()
             .doOnSubscribe(() -> isSubscribed.onNext(true))
             .doOnUnsubscribe(() -> isSubscribed.onNext(false))
@@ -53,6 +53,7 @@ protected void protectedRun() {
                 // when there are no subscribers there is no point of continuing work -> next will be disconnect operation
                 .takeUntil(asObservableHasNoSubscribers().doOnNext(noSubscribers -> RxBleLog.d("No subscribers, finishing operation")))
                 .doOnCompleted(onConnectionEstablishedRunnable::run)
+                .doOnNext(ignored -> isSubscribed.onCompleted())
                 .subscribe(getSubscriber());
         onConnectCalledRunnable.run();
     }