Исключение: blockingConnect не следует вызывать в потоке пользовательского интерфейса, несмотря на то, что я добавил другой поток

У меня есть вызов следующим образом:

val connectionResult = googleApiClient.blockingConnect() 

что является причиной этого исключения:

java.lang.IllegalStateException: blockingConnect не должен вызываться в потоке пользовательского интерфейса

 at com.google.android.gms.common.internal.zzbp.zza(Unknown Source) at com.google.android.gms.common.api.internal.zzbd.blockingConnect(Unknown Source) at com.elstatgroup.elstat.NexoLocationManager.startLocationUpdatesGmsApi(NexoLocationManager.kt:510) at com.elstatgroup.elstat.NexoLocationManager.startLocationUpdates(NexoLocationManager.kt:498) at com.elstatgroup.elstat.NexoLocationManager.appendRSSIEvent(NexoLocationManager.kt:283) at com.elstatgroup.elstat.NexoLocationManager.appendRSSIEvent(NexoLocationManager.kt:273) at com.elstatgroup.elstat.NexoLocationTest.testAppendLocationEvents(NexoLocationTest.kt:111) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50) at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47) at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) at org.robolectric.RobolectricTestRunner$HelperTestRunner$1.evaluate(RobolectricTestRunner.java:497) at org.robolectric.internal.SandboxTestRunner$2.evaluate(SandboxTestRunner.java:228) at org.robolectric.internal.SandboxTestRunner.runChild(SandboxTestRunner.java:110) at org.robolectric.internal.SandboxTestRunner.runChild(SandboxTestRunner.java:37) at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290) at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71) at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288) at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58) at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268) at org.robolectric.internal.SandboxTestRunner$1.evaluate(SandboxTestRunner.java:64) at org.junit.runners.ParentRunner.run(ParentRunner.java:363) at org.junit.runner.JUnitCore.run(JUnitCore.java:137) at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68) at com.intellij.rt.execution.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:51) at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:242) at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70) 

Я думал, что это поможет:

  Observable.just(googleApiClient.blockingConnect()) .subscribeOn(Schedulers.newThread()) .subscribe(Consumer { connectionResult -> if (connectionResult.isSuccess()) { //do something } }) 

Но я ошибаюсь, и это не помогает. Единственное, что я делаю, это не крах:

  Thread(Runnable { val connectionResult = googleApiClient.blockingConnect() if (connectionResult.isSuccess()) { //do something } }).start() 

Так почему мое решение RxJava не работает?

Observable.just() принимает значение (-ы), которое / передается в следующую цепочку. Если вы внимательно изучите, то в вашем случае здесь

 Observable.just(googleApiClient.blockingConnect()) 

googleApiClient.blockingConnect() запускается сначала, так just оператору требуется значение / значения. Поэтому вам нужен оператор здесь, который принимает вызов функции или что-то в этом роде.

Для вашего случая можно использовать Observable.fromCallable() , который получает вызываемый как параметр:

 Observable.fromCallable(() -> googleApiClient.blockingConnect()); 

Здесь googleApiClient.blockingConnect() будет выполняться при подписке на наблюдаемую цепочку.

Это связано с тем, что Observable # просто стремится и будет блокироваться до завершения #blockingConnect.

Этот пример должен сделать трюк:

  Observable.fromCallable(() -> { return googleApiClient.blockingConnect(); }).subscribeOn(Schedulers.io());