Join FlipAndroid.COM Telegram Group: https://t.me/joinchat/F_aqThGkhwcLzmI49vKAiw


Tag: rx java

RxJava patrón para solicitar un remoto Observable con una caché temporal

El caso de uso es el siguiente: Quiero almacenar temporalmente en caché la última respuesta Observable observada emitida, pero después de que expire, regresar a la costosa fuente Observable y guardarla de nuevo, etc. Un escenario de caché de red bastante básico, pero realmente estoy luchando para que funcione. private Observable<String> getContentObservable() { // expensive […]

Comprobación de Internet, dónde colocar al usar MVP, RX y Retrofit

He pasado por esto y este post. Así que estoy realmente de acuerdo con el segundo post que el presentador no debe ser consciente de la cosa específica de Android. Así que lo que estoy pensando es poner la comprobación de Internet en la capa de servicio. Estoy utilizando Rx Java para hacer llamadas de […]

Manejar errores en Retrofit 2 RX

Mi solicitud debe obtener JSON para POJO o JSON descrito error (puede ser campos de solicitud no válida, problemas de servidor y así sucesivamente). Pero la actualización en el suscriptor me da sólo Throwable. ¿Cómo puedo averiguar es que un error de red, lo que es el código http, y obtener JSON con error? private […]

Por qué definir Flowable podría recibir actualizaciones de la base de datos

@Query("SELECT * FROM userdata") Flowable<List<UserData>> allUserDatas(); @Insert(onConflict = OnConflictStrategy.REPLACE) List<Long> insert(List<UserData> datas); userDao.allUserDatas() take(1). filter(….) .subscribeOn(io()) .observeOn(mainThread()) .subscribe(userDatas -> Log.i("TAG",""+userDatas)); He añadido la búsqueda con la suscripción en el mismo fragmento en onAttach (), pero después de la actualización de DB no llama a la suscripción de la búsqueda de DB, ¿por qué

RxJava y eventos esporádicos al azar en Android

Quiero usar RxJava como yo usaría el EventBus de Guava o Otto, pero no veo cómo puedo conseguir que funcione de esa manera. Este es el escenario: digamos que quiero tener un botón en mi aplicación para Android y cada vez que se presiona un botón, quiero que RxJava emita un evento a través de […]

¿Es posible obtener 2 valores en onNext () de suscriptor en rxjava android?

Tengo un observable como este Observable.zip(observable, extObs, new Func2<List<UserProfile>, ArrayList<Extension>, UserProfile>() { @Override public UserProfile call(List<UserProfile> userProfiles, ArrayList<Extension> extensions) { return userProfiles.get(0); } }).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).unsubscribeOn(Schedulers.io()).subscribe(new Subscriber<UserProfile>() { @Override public void onCompleted() { } @Override public void onError(Throwable e) { e.printStackTrace(); } @Override public void onNext(UserProfile userProfile) { profileListener.onProfileSet(userProfile); } }); } Necesito pasar el ArrayList en […]

¿Cómo implementar la función de búsqueda con SearchView, Retrofit y RxJava (RxBindings)?

Cuando el usuario escribe en el widget SearchView , la aplicación debe realizar una llamada a la API ( en el subproceso de fondo ) para buscar los resultados de búsqueda desde el servidor y mostrarlos ( en el subproceso de la interfaz de usuario ) en RecyclerView. Utilizo el siguiente código en mi fragmento: […]

¿Cómo puedo implementar el equivalente RxJava de INotifyPropertyChanged para hacer un modelo de datos Observable?

Soy nuevo en Java y nuevo en Rx. Estoy en el fondo. Estoy en las primeras etapas de escribir una aplicación para Android que usará un patrón MVC (Model-View-Controller) y estoy experimentando con varias maneras de hacerlo, en particular RxJava. Mi idea es hacer que mi modelo sea Observable y mi View the Observer . […]

Implementar reintento Cuando la lógica

Tengo una aplicación que requiere sesiones (cookies) para procesar llamadas web. Estoy usando Retrofit+RxJava . Sin embargo, la sesión podría caducar (error de retroactivación con estado 401 no autorizado) y quiero volver a autenticar (para obtener cookies nuevas) y reintentar llamadas anteriores en este caso. ¿Cómo lo haría con RxJava ? Mi ejemplo: getServerApi().getDialogs(offset, getCookies()) […]

¿Cómo recuperar cuerpo de respuesta con RxAndroid y Retrofit 2?

Estoy utilizando Retrofit 2 (beta 4), y yo estaba mirando para pasar de usar la respuesta de Call estándar a la respuesta RxAndroid Observable . He tenido éxito al cambiar la mayoría de mis llamadas con un simple intercambio de Call<List<ExampleObject>> a Observable<List<ExampleObject>> . Algunas de mis llamadas utilizan Call<okhttp3.ResponseBody> , que funciona muy bien, […]

FlipAndroid es un fan de Google para Android, Todo sobre Android Phones, Android Wear, Android Dev y Aplicaciones para Android Aplicaciones.