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
- La suscripción de rx kotlin no funciona, no recibe artículos
- ¿Cómo leer JSON desde Url usando kotlin Android?
- Inyectar constructor y object complementario
- cómo implementar Switch usando Data binding en android
- Para una function de Kotlin utilizada como expresión, ¿hay una forma concisa de operar y devolver un valor?
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)
- Rx-Kotlin awaitTerminalEvent nunca se sube a Completo
- RxKotlin flattenAsObservable (): no coincide con el método de reference
- RxKotlin - matriz de observadores dynamics
- ¿Cómo hacer un grupo? ¿Por qué coleccionar usando RxJava y Kotlin?
- Repetir acciones en estado con RxJava
- RxJava2 Tal vez devuelva Observable vacío si no hay elemento
- No se puede cambiar el text de ActionMenuItemView con RxKotlin
- Obligatorio <Objeto> y encontrado <Objeto>?
¡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
- El método de callback a menudo para reenviar el evento a Observable?
- Reaccionar a la llamada de actualización