Tag: rx java

Retrofit no desencadena onError cuando se utiliza ErrorHandler personalizado

Estoy utilizando Retrofit 1.9.0, RxJava 1.0.10, RxAndroid 0.24.0 y OkHttp 2.4.0. Cuando estoy configurando los métodos personalizados de ErrorHandler RxJava Subscriber no se activan. ¿Por qué? ¿Es posible cambiar este comportamiento? Estoy adjuntando el código fuente. Inicialización: HttpClient: OkHttpClient httpClient = new OkHttpClient(); httpClient.setHostnameVerifier(…); // allow all try { httpClient.setSslSocketFactory(…); } catch (NoSuchAlgorithmException | KeyManagementException […]

¿Cómo ejecutaría esta sentencia usando RxJava?

Rx manera de hacer las cosas puede ser muy complejo para ninguno y por muchas razones … pero siento que hay formas sencillas de hacer cosas simples con RX … ¿Cómo podría simplemente realizar esta declaración en un hilo de fondo y recibir la respuesta en el hilo ui? Todas las funciones de este objeto […]

RxJava: ¿Cómo reanudar el trabajo de un observable si se produce un cambio de configuración?

Trabajo con RxJava y RxAndroid . ¿Cómo reanudar el trabajo de un observable si se produce un cambio de configuración (rotación de actividad, cambio de idioma local, etc.)? Necesito no sólo reanudar el trabajo de un observable, también necesito excepto los artículos emitidos, cuando el suscriptor es unsubscribed y emite todos los artículos ahorrados enseguida […]

RxJava + retrofit, obtenga una lista y agregue información adicional para cada artículo

Estoy jugando con RXJava, retrofit en Android. Estoy tratando de lograr lo siguiente: Necesito hacer una encuesta periódicamente una llamada que me da un Observable> (Desde aquí podría hacerlo) Una vez que consiga esta lista quiero iterar en cada entrega y llamar a otros métodos que me dará la ETA (tan sólo más información) Quiero […]

En RxJava, cómo reintentar / reanudar en caso de error, en lugar de completar el observable

Lo que quiero lograr es: Supervisar las preferencias de un determinado cambio Cuando se detecta un cambio, iniciar nueva llamada de red utilizando el nuevo valor Transformar resultado Mostrar el resultado en la interfaz de usuario Sé cuándo sucede el cambio, ahora presumo que necesito llamar al siguiente en un asunto. Esto debería activar una […]

Compartiendo RxBindings Eventos observables entre múltiples suscriptores

Estoy usando un Focus Observable de la biblioteca de RxBindings para reaccionar en los cambios de enfoque. Como quiero validar la entrada y activar una animación necesito los eventos de enfoque dos veces. Jake Wharton recomienda utilizar el operador share () para múltiples suscripciones en una observable. Pero si manipulo el observable después de usar […]

RxJava para Android: Exponer Excepción y Reintentar (con retraso)

Tengo el siguiente Observable que ejecutará una llamada REST con retrofit cada 30 segundos: Subscription subscription = Observable.interval(0, REFRESH_INTERVAL, TimeUnit.SECONDS) .concatMap(new Func1<Long, Observable<Response>>() { @Override public Observable<Response> call(Long time) { return webservice.callRetrofitServiceWithRx(parameter); } }) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new UpdateSuccessAction(), new UpdateErrorAction()); Puede suceder que (especialmente el REST-Call) lanzará una excepción (por ejemplo, no hay conexión a […]

Encadenamiento de dos llamadas de servicio web mediante RxJava y Retrofit

Estoy utilizando RxJava y Retrofit.My requisito básico es, quiero encadenar dos api llamadas, que se llaman uno tras otro. La respuesta recibida desde el primer api se utiliza como entrada mientras se llama al segundo api. Después de leer algunas cosas en internet yo solía planear para lograr esto. Mientras que realiza esta operación estoy […]

RxJava dividir uno Observable a dos subObservables

Soy totalmente nuevo a RxJava y lo he pasado todo el día entendiéndolo, estoy atando para pensar cómo solucionar este problema: Tengo un objeto, buscado por Retrofit , contiene dos ArrayLists , tengo que procesar cada ArrayList diferentemente. Actualmente se ve como: apiService.getUser(token).enqueue(new Callback<User>() { @Override public void onResponse(Response<User> response) { final User user = […]

RXJava – ejecuta múltiples observables tras otro (como concat, pero con onCompleted para cada observable)

¿Hay alguna manera de lograr lo siguiente: Tengo 3 observables del tipo Observable<MyData> . Lo que quiero es seguir: Ejecutar el primer observable Observar el onCompleted de la primera observable Ejecutar el segundo observable Observar el onCompleted de la segunda observable Ejecutar el tercer observable Observar el onCompleted de la tercera observable Esto se puede […]