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

  • RxAndroid, cómo detectar si observable ha finalizado la emisión
  • cómo implementar Switch usando Data binding en android
  • Cómo pasar nulo a un Observable con tipo anulable en RxJava 2 y Kotlin
  • Para una function de Kotlin utilizada como expresión, ¿hay una forma concisa de operar y devolver un valor?
  • ¿Cómo leer JSON desde Url usando kotlin Android?
  • ¿Cómo hacer un grupo? ¿Por qué coleccionar usando RxJava y Kotlin?
  • Comportamiento con Kotlin Higher-Order Functions e interfaces de método único?
  • Múltiples requestes de modificación2 usando Flowable en Kotlin
  • RxKotlin - matriz de observadores dynamics
  • Excepción causada por: java.lang.ClassNotFoundException: org.reactivestreams.Publisher
  • Agregar subscribeOn () está cambiando el tipo de retorno de observable