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

  • Cómo notificar a Observable cuando finalice CountdownTimer
  • RxKotlin flattenAsObservable (): no coincide con el método de reference
  • Spring 5 and Kotlin 1.1 Coroutines: Type rx.Scheduler no presente
  • RxJava2 Tal vez devuelva Observable vacío si no hay elemento
  • RxKotlin - matriz de observadores dynamics
  • No se puede cambiar el text de ActionMenuItemView con RxKotlin
  • La suscripción de rx kotlin no funciona, no recibe artículos
  • 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
  • Kotlin con stack RxKotlinFX da un error de class de acceso
  • RxJava- Gire Observable en Iterator, Stream o Sequence