Fixed IllegalStateException on RxBleAdapterStateObservable (#596)

Setting a cancelable on an Emitter did run it immediately if it was already disposed. Postponing the setting until after the BroadcastReceiver is registered fixed the issue.
dariuszseweryn · Jun 28, 2019 · f19f46f · f19f46f
1 parent af902c8
commit f19f46f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rxandroidble/src/main/java/com/polidea/rxandroidble2/RxBleAdapterStateObservable.java b/rxandroidble/src/main/java/com/polidea/rxandroidble2/RxBleAdapterStateObservable.java
@@ -67,13 +67,13 @@ public void onReceive(Context context, Intent intent) {
                         emitter.onNext(internalState);
                     }
                 };
+                context.registerReceiver(receiver, new IntentFilter(BluetoothAdapter.ACTION_STATE_CHANGED));
                 emitter.setCancellable(new Cancellable() {
                     @Override
                     public void cancel() {
                         context.unregisterReceiver(receiver);
                     }
                 });
-                context.registerReceiver(receiver, new IntentFilter(BluetoothAdapter.ACTION_STATE_CHANGED));
             }
         })
                 .subscribeOn(Schedulers.trampoline())