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
- RxAndroid, cómo detectar si observable ha finalizado la emisión
- No se puede 'observar en' hilo principal con RxKotlin
- ¿Expresar "súper" generics en los types funcionales de Kotlin?
- RxJava - ¿Entradas de keyboard de contrapresión?
- Spring 5 and Kotlin 1.1 Coroutines: Type rx.Scheduler no presente
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)
- RxKotlin - matriz de observadores dynamics
- ¿Cómo puedo agregar de manera condicional una operación asincrónica en medio de una transmisión de RxJava?
- Obligatorio <Objeto> y encontrado <Objeto>?
- Agregar subscribeOn () está cambiando el tipo de retorno de observable
- ¿Cómo hacer un grupo? ¿Por qué coleccionar usando RxJava y Kotlin?
- ¿Cómo corotines de Kotlin son mejores que RxKotlin?
- Cómo comprimir algunos observables en lenguaje Kotlin con RxAndroid
- Inyectar constructor y object complementario
¡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