Articles of Progtwigción reactiva

Conmutación de Observables

Tengo dos observables ob1 y ob2 . Ahora tengo que cambiar entre ob1 y ob2 function de la condición de que cambie a ob2 cuando ob1 no esté emitiendo y vuelva a ob1 cuando comience a emitir.

Combinando los resultados de múltiples observables

Estoy tratando de lograr algo como esto: – Hacer dos llamadas API diferentes y combinar los resultados en una list. El resultado de cada llamada es un HashMap y tengo una function para convertirlo en una list. Lo que trato de hacer ahora es combinar las lists en una, pero estoy teniendo dificultades. Este es […]

RxJava Valor pnetworkingeterminado para throttleFirst

¿Cómo proporcionar un valor pnetworkingeterminado para throttleFirst cuando la fuente observable no emite nada en el intervalo de time dado? ob1.throttleFirst(1, TimeUnit.SECONDS) He intentado defaultIfEmpty() pero parece que no funciona.

¿Cómo puedo pausar que un evento fluya a través de un observable?

Intento crear un Observable que se pueda pausar de tal forma que los elementos dejen de ser empujados a través de lo observable hasta que no se pause. En ese punto, me gustaría que reanude el procesamiento de todos los elementos sin procesar. Mi fuente de datos proviene de fuera de la class, así que […]

¿Cómo hacer un grupo? ¿Por qué coleccionar usando RxJava y Kotlin?

Tengo Observable<Rates> y Rate es solo un simple object: Rate(val value:String){} Rates(val rates: List<Rate>) y quiero cambiar ese Observable<Rates> en Observable<HashMap<String,Long> . por ejemplo, para tarifas Rates(arrayOf(Rate("1"),Rate("2"), Rate("3"),Rate("3"), Rate("2"),Rate("2"))) espero resultado: (1 -> 1) (2 -> 3) (3 -> 2) (4 -> 0) (5 -> 0) Comienzo a crear algo así: service.getRates() .flatMap {it-> Observable.from(it.rates) […]