Articles of rx android

OnComplete nunca se llamó con toSortedList () y groupBy ()

Actualmente estoy usando la Biblioteca de ReactiveLocation de Android ( Github ). LastKnownLocationObservable ( Code ) funciona según lo previsto. Estoy usando flatMap para search estaciones cercanas desde un DB y (debido a su dominio) estoy creando un model a partir de los datos. Así que tengo una list de elementos y estoy creando el […]

¿Cómo convertir muchas AsyncTasks a Rx Observables en Android?

Estoy usando Facebook Graph API para encontrar usuarios a los que les hayan gustado mis publicaciones. Toda la lógica se implementa en pocos pasos: Encuentra todas las publicaciones haciendo request a API en AsyncTask Convierte este AT a Rx.Observable Map Observables GraphResponse to List (El comentario es POJO) Llame al operador de FlatMap y en […]

Cómo get Flowable <List <Foo >> del object 'Bar' con relaciones de uno a muchos 'Foo' usando el reino y Rxjava

Digamos que tengo una class model como esta. Copio desde aquí. open class Person( @PrimaryKey var id: Long = 0, var name: String = "", var age: Int = 0, var dog: Dog? = null, var cats: RealmList<Cat> = RealmList(), ) : RealmObject() { } Hay muchas personas y cada persona tiene uno o más […]

RxKotlin – matriz de observadores dynamics

Estoy usando RxKotlin junto con Retrofit 2 Estoy intentando descubrir cómo tener una list dinámica de observadores en una sola operación. El primer observador debe activar la operación, y todos los observadores adicionales deben esperar hasta que la operación se complete / falla Una vez que la operación se completa, necesito realizar la manipulación de […]

¿Cómo iterar sobre Single <List> y asignar a otra list?

como resultado de la request de actualización obtengo Single<List<Info>> Debo iterar sobre cada elemento y, en function de cada ID de elemento, debo llamar a otra request que también es Single Y luego asignarme a DetailInfo y como resultado tener Single<List<DetailInfo>> Encontré flattenAsObservable y flattenAsFlowable, no estoy seguro de usarlo, es el enfoque correcto; si […]

RxAndroid: al usar RxView.touches se borran otros controlleres

Estoy tratando de agregar controller táctil a FabricView , pero parece que al hacerlo no puedo seguir dibujando . De hecho, la propia FabricView define un controller de Touch, pero parece que mi bash, utilizando RxAndroid2, borra el controller pnetworkingefinido, en lugar de encadenarlo. Lo que me gustaría es poder usar mi controller, sin borrar […]

RxJava Live Reactive Queue (con el interruptor de apagado)

Trabajando en una aplicación de Android en Kotlin. Necesito configurar un sistema para poder hacer trabajo desde una queue en vivo (y observar los resultados del trabajo en una secuencia). Pero también tengo que ser capaz de alternar el "procesamiento de queue" dependiendo de un par de factores externos (que también vienen como transmisiones) como […]

RxAndroid – Manejar errores con el operador Zip

Estoy tratando de encontrar una forma de ejecutar requestes en paralelo y manejarlas cuando finalice cada observación. A pesar de que todo está funcionando cuando todos los observables dan una respuesta, no veo una forma de manejar cada uno de los errores cuando todo está terminado. Esta es una muestra del operador zip, que básicamente […]

¿Cómo obtengo los encabezados de respuesta con RxAndroid + Retrofit en Kotlin?

Tengo un API observable que devuelve CUSTOM_MODEL. Me gustaría get los encabezados de respuesta de esta llamada también.

RxAndroid, cómo detectar si observable ha finalizado la emisión

Estoy escribiendo el siguiente fragment de código para recuperar la list de alimentos guardados de la database de firebase y luego, al usar esa list, vuelvo a search detalles de alimentos individuales de la database de firebase. El siguiente código funciona bien, excepto que no puedo averiguar cómo hacer que el segundo flatMap sepa que […]