Removed DisposableObserver wrapping in LocationServicesOkObservable (#…

…574) Seems unnecessary
dariuszseweryn · May 17, 2019 · b413667 · b413667
1 parent 9d7f60f
commit b413667
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/...roidble/src/main/java/com/polidea/rxandroidble2/helpers/LocationServicesOkObservable.java b/...roidble/src/main/java/com/polidea/rxandroidble2/helpers/LocationServicesOkObservable.java
@@ -5,15 +5,13 @@
 
 import com.polidea.rxandroidble2.ClientComponent;
 import com.polidea.rxandroidble2.DaggerClientComponent;
-import com.polidea.rxandroidble2.internal.util.DisposableUtil;
 
 import java.util.UUID;
 
 import bleshadow.javax.inject.Inject;
 import bleshadow.javax.inject.Named;
 import io.reactivex.Observable;
 import io.reactivex.Observer;
-import io.reactivex.observers.DisposableObserver;
 
 /**
  * An Observable that emits false if an attempt to scan with {@link com.polidea.rxandroidble2.RxBleClient#scanBleDevices(UUID...)}
@@ -43,8 +41,6 @@ public static LocationServicesOkObservable createInstance(@NonNull final Context
 
     @Override
     protected void subscribeActual(final Observer<? super Boolean> observer) {
-        final DisposableObserver<? super Boolean> disposableObserver = DisposableUtil.disposableObserver(observer);
-        observer.onSubscribe(disposableObserver);
-        locationServicesOkObsImpl.subscribeWith(disposableObserver);
+        locationServicesOkObsImpl.subscribe(observer);
     }
 }