No se puede 'observar en' hilo principal con RxKotlin

Estoy tratando de observar observable en el hilo principal usando:

// Kotlin Code Observable .observeOn(AndroidSchedulers.mainThread()) 

pero estoy obteniendo el siguiente error:

  Type Mismatch: Requinetworking: rx.Scheduler! Found: io.reactivex.Scheduler! 

El Observable al que me suscribo pertenece a una Biblioteca que está escrita en Java y, por lo tanto, usa RxJava.

¿Estoy siendo estúpido y me estoy perdiendo algo? Estoy desconcertado: $

Gracias por adelantado 🙂

  Requinetworking: rx.Scheduler! 

Requinetworking significa que la firma es Observable.observeOn(rx.Scheduler)

  Found: io.reactivex.Scheduler! 

Found significa que la firma es io.reactivex.Scheduler AndroidSchedulers.mainThread()

Esto significa que el Observable es un RxJava 1 observable, mientras que la versión RxAndroid utilizada está construida para RxJava 2. Como mencionó que el observable es provisto por una biblioteca, significa que la biblioteca está construida usando RxJava 1.

Tienes 3 opciones para arreglar esto:

  1. Averiguar si la biblioteca en cuestión tiene una versión RxJava 2, o contribuir con esas actualizaciones al proyecto usted mismo.
  2. Utilice akarnokd / RxJava2Interop para convertir el antiguo Observable a RxJava 2. ( RxJavaInterop.toV2Observable(Observable); )
  3. Cambie las otras dependencies a RxJava 1.

por favor incluya esto en su import gradle

rxandroid_version = "2.0.1"

implementación "io.reactivex.rxjava2: rxandroid: $ rxandroid_version"

agregar esto a su proyecto

import io.reactivex.android.schedulers.AndroidSchedulers

  • Excepción causada por: java.lang.ClassNotFoundException: org.reactivestreams.Publisher
  • Repetir acciones en estado con RxJava
  • ¿Cómo corotines de Kotlin son mejores que RxKotlin?
  • OnComplete nunca se llamó con toSortedList () y groupBy ()
  • Cómo comprimir algunos observables en lenguaje Kotlin con RxAndroid
  • La biblioteca de Kotlin 'rxkotlin-0.21.0.jar' tiene un formatting no compatible. Actualice la biblioteca o el complemento
  • Llamada asincrónica para cada elemento dentro de una colección
  • ¿Cómo hacer un grupo? ¿Por qué coleccionar usando RxJava y Kotlin?
  • Cómo pasar nulo a un Observable con tipo anulable en RxJava 2 y Kotlin
  • RxKotlin - matriz de observadores dynamics
  • RxJava2 Tal vez devuelva Observable vacío si no hay elemento