Resultados de la búsqueda a petición "rx-java"
Listas de unión de Android RxJava
Tratando de entender todas esas cosas de RxJava. Estaba haciendo el siguiente ejemplo: private Observable<List<String>> query1() { List<String> urls = new ArrayList<>(); urls.add("1"); urls.add("2"); urls.add("3"); urls.add("4"); return ...
RxJava + actualización, obtenga una Lista y agregue información adicional para cada elemento
Estoy jugando con RXJava, actualización en Android. Estoy tratando de lograr lo siguiente: Necesito sondear periódicamente una llamada que me da un Observable> (Desde aquí podría hacerlo) Una vez que obtenga esta lista, quiero iterar en cada ...
Kotlin: ¿Qué significa "return @"?
Estoy usando RxJava en uno de mis proyectos, convertí una de mis clases a Kotlin usando el complemento de Android Studio y en uno de mapflatMap lambda (Func1 en java), los retornos intermedios se parecen a los siguientes@Func1. No tengo idea de ...
Use RxJava y Retrofit para iterar a través de la lista y aumentar los resultados basados en subconsultas
Estoy usando la actualización y siento que rxjava (con retrolambda) sería una buena opción para el siguiente flujo: obtener una lista de widgets (http)para cada widget a) obtener una lista de artículos (http) para el tipo de widget dado b) ...
RxJava comparte las emisiones de un Observable entre múltiples suscriptores
Tengo el siguiente problema: Tengo un observable que está haciendo algo de trabajo, pero otros observables necesitan la salida de ese observable para funcionar. He intentado suscribirme varias veces en el mismo observable, pero dentro del ...
¿Cómo usar Observable.fromCallable () con una excepción marcada?
Observable.fromCallable() es ideal para convertir una sola función en un Observable. Pero, ¿cómo maneja las excepciones marcadas que podría generar la función? La mayoría de los ejemplos que he visto usan lambdas y "simplemente funcionan". ¿Pero ...
Aplicar reintentos en un RXjava
Quiero ejecutar un método con reintentos usando RXJava return Observable .just(myObj) .flatMap(doc -> myFunc(myObj, ....) ) .doOnError(e -> log.Error()) .onErrorResumeNext(myObj2 -> methodIWantToRunWithRetries(...) .onErrorResumeNext(myObj3 ...
¿Cómo transformar una lista anidada de valores dobles en una clase Java usando RxJava?
En mi cliente Android, recibo estos datos JSON de un servidor: [ [ 1427378400000, 553 ], [ 1427382000000, 553 ] ]Aquí está la rutina que realmente carga los datos. estoy ...
RxAndroid y Retrofit: no se puede crear el adaptador de llamada para io.reactivex.Observable <retrofit2.Response <okhttp3.ResponseBody >>
Estoy intentando usar rxJava, rxAndroid, Retrofit2 y OkHTTP3 para descargar un archivo desde un punto final de URL. Mi código no puede crear el adaptador de llamada para un "Observable <retrofit2.Response <okhttp3.ResponseBody >>". Estos métodos ...