RxJava (Kotlin), Observable.amb y PublishSubject no están disparando

Estamos intentando observar un intervalo de 15 onNext o cada vez que onNext en nuestro tema refreshEventsSubject , pero sin éxito.

El sujeto se inicia como tal

private val refreshEventsSubject = PublishSubject<Long>()

Y luego tratamos de observarlo así

Observable.merge(Observable.interval(0, 15, TimeUnit.SECONDS), refreshEventsSubject) .subscribe { ... }

Obtenemos los events del intervalo cada 15 segundos, pero el sujeto no está disparando después de ejecutar

refreshEventsSubject.onNext(0)

Cualquier idea apreciada.

(Todo está escrito en Kotlin)

¡Asegúrate de que no se refreshEventsSubject.onNext(0) desde tu hilo principal ya que puede causar lockings!

También use http://reactivex.io/documentation/operators/amb.html en lugar de fusionar, ya que fusionará dos events oppon llamando a Next en su tema.

Lea la documentation de AMB: http://reactivex.io/documentation/operators/amb.html

Específicamente, emit all of the items from only the first of these Observables to emit an item or notification .

El operador que está buscando es probablemente Observable.merge : http://reactivex.io/documentation/operators/merge.html

  • Obligatorio <Objeto> y encontrado <Objeto>?
  • Múltiples requestes de modificación2 usando Flowable en Kotlin
  • cómo implementar Switch usando Data binding en android
  • Kotlin con stack RxKotlinFX da un error de class de acceso
  • ¿Cómo puedo agregar de manera condicional una operación asincrónica en medio de una transmisión de RxJava?
  • La biblioteca de Kotlin 'rxkotlin-0.21.0.jar' tiene un formatting no compatible. Actualice la biblioteca o el complemento
  • Cómo comprimir algunos observables en lenguaje Kotlin con RxAndroid
  • RxJava2 Tal vez devuelva Observable vacío si no hay elemento
  • RxKotlin collectInto () MutableList usando references de método
  • No se puede cambiar el text de ActionMenuItemView con RxKotlin
  • Cómo notificar a Observable cuando finalice CountdownTimer