Excepción: blockingConnect no se debe invocar en el subprocess UI a pesar de que subsubscribí en otro subprocess

Tengo una invocación como esta:

val connectionResult = googleApiClient.blockingConnect() 

que es la causa de esta exception:

java.lang.IllegalStateException: blockingConnect no debe invocarse en el hilo de la interfaz de usuario

 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) 

Pensé que esto ayudaría:

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

Pero estoy equivocado y esto no ayuda. La única forma en que lo hago no se cuelga es este:

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

Entonces, ¿por qué mi solución RxJava no funciona?

Observable.just() acepta valor (es) que se pasa (n) a la siguiente observación encadenada. Si examinas detenidamente, entonces en tu caso aquí

 Observable.just(googleApiClient.blockingConnect()) 

googleApiClient.blockingConnect() se ejecuta primero ya que just operador necesita un valor / valores. Entonces necesitas un operador aquí que acepte una llamada a function o algo así.

Para su caso, se puede usar Observable.fromCallable() que recibe un parámetro invocable:

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

Aquí googleApiClient.blockingConnect() se ejecutará cuando se suscriba a la cadena observable.

Esto se debe a que Observable # simplemente está ansioso y se bloqueará hasta que finalice #blockingConnect.

Este ejemplo debería hacer el truco:

  Observable.fromCallable(() -> { return googleApiClient.blockingConnect(); }).subscribeOn(Schedulers.io()); 
  • Escuchar posts y escribir commands en un flujo observable
  • Cómo get el último valor emitido de observable
  • Kotlin y RxJava2 zip operator - Ninguna de las siguientes funciones puede invocarse con los arguments suministrados
  • Invoque RxJava2 cancelable / desechable del hilo correcto
  • Manejo de errores de suscripción anidada RX2.0
  • HttpException no capturado por onError ()
  • Convierte el código de RxJava a Kotlin correctamente
  • Mockito never () no funciona con andThen rxjava2
  • Cómo hacer que la function regrese Observable
  • RxJava 1.x .zip () no funciona en RxJava 2.0
  • Rx-Kotlin awaitTerminalEvent nunca se sube a Completo