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

  • Comportamiento con Kotlin Higher-Order Functions e interfaces de método único?
  • RxJava (Kotlin), Observable.amb y PublishSubject no están disparando
  • La suscripción de rx kotlin no funciona, no recibe artículos
  • Obtiene N últimos objects emitidos por observables en RxJava2
  • No se puede cambiar el text de ActionMenuItemView con RxKotlin
  • ¿Puedo crear un método de extensión Kotlin para agregar una suscripción rxJava a una suscripción compuesta?
  • RxKotlin - matriz de observadores dynamics
  • Llamada asincrónica para cada elemento dentro de una colección
  • RxJava - ¿Entradas de keyboard de contrapresión?
  • Para una function de Kotlin utilizada como expresión, ¿hay una forma concisa de operar y devolver un valor?
  • RxJava2 Tal vez devuelva Observable vacío si no hay elemento