Add logs to show potential errors (#429)

In an edge-case scenarios it is possible that the library will hang. Added error logs for this situations.
dariuszseweryn · Jun 13, 2018 · e043356 · e043356
1 parent 9008978
commit e043356
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/rxandroidble/src/main/java/com/polidea/rxandroidble2/internal/QueueOperation.java b/rxandroidble/src/main/java/com/polidea/rxandroidble2/internal/QueueOperation.java
@@ -36,13 +36,15 @@ public final Observable<T> run(final QueueReleaseInterface queueReleaseInterface
         return Observable.create(
                 new ObservableOnSubscribe<T>() {
                     @Override
-                    public void subscribe(ObservableEmitter<T> emitter) throws Exception {
+                    public void subscribe(ObservableEmitter<T> emitter) {
                         try {
                             protectedRun(emitter, queueReleaseInterface);
                         } catch (DeadObjectException deadObjectException) {
                             emitter.tryOnError(provideException(deadObjectException));
+                            RxBleLog.e(deadObjectException, "QueueOperation terminated with a DeadObjectException");
                         } catch (Throwable throwable) {
                             emitter.tryOnError(throwable);
+                            RxBleLog.e(throwable, "QueueOperation terminated with an unexpected exception");
                         }
                     }
                 }