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
- ¿Cómo hacer un grupo? ¿Por qué coleccionar usando RxJava y Kotlin?
- ¿Cómo corotines de Kotlin son mejores que RxKotlin?
- OnComplete nunca se llamó con toSortedList () y groupBy ()
- Usando RxJava para unir datos locales con datos remotos (o en caching)
- RxKotlin - Single.just () no se emite al suscribirse TestSubscriber
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 flattenAsObservable (): no coincide con el método de reference
- RxKotlin - matriz de observadores dynamics
- Llamada asincrónica para cada elemento dentro de una colección
- Crear nueva instancia de object Kotlin
- ¿Expresar "súper" generics en los types funcionales de Kotlin?
- RxJava- Gire Observable en Iterator, Stream o Sequence
- Spring 5 and Kotlin 1.1 Coroutines: Type rx.Scheduler no presente
- Cómo pasar nulo a un Observable con tipo anulable en RxJava 2 y 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
- El método de callback a menudo para reenviar el evento a Observable?
- Reaccionar a la llamada de actualización