Resultados de la búsqueda a petición "rx-java"
Cómo manejar errores de red en Retrofit 2 con RxJava
Estoy usando Retrofit2 con RxJava. Entonces mi llamada se parece a algo subscriptions.add(authenticateUser(mReq, refreshRequest) .observeOn(Schedulers.io()) .subscribeOn(Schedulers.io()) .subscribe(authResponseModel -> { ...
RxJava: Cómo aplicar operadores condicionalmente a un observable sin romper la cadena
Tengo una cadena de operadores en un RxJava observable. Me gustaría poder aplicar uno de dos operadores dependiendo de un valor booleano sin "romper la cadena". Soy relativamente nuevo en Rx (Java) y siento que probablemente haya una forma más ...
Android Retrofit 2 + RxJava: escucha transmisiones sin fin
¿Puedo usar Retrofit + RxJava para escuchar una transmisión sin fin? Por ejemplo, la transmisión de Twitter. Lo que tengo es esto: public interface MeetupAPI { @GET("http://stream.meetup.com/2/rsvps/") Observable<RSVP> getRSVPs(); } MeetupAPI ...
RxAndroid - reintente observable al hacer clic
Estoy usando rxAndroid y rxKotlin en mi aplicación de Android para manejar solicitudes de red de forma asincrónica. Ahora me gustaría volver a intentar una solicitud de red fallida solo después de hacer clic en el botón Snackbar. Mi código ...
Firebase offline sin CompletionListener en setValue
Tengo esta base de código donde establezco un valor. En el modo fuera de línea, escribe correctamente pero no llama a la función de devolución de llamada CompletionListener.onComplete. newOrderRef.setValue(order, (firebaseError, firebase) -> { ...
RxJava reintenta cuando hay un comportamiento extraño
Estoy jugando con el RxJavareintentarCuando [http://reactivex.io/documentation/operators/retry.html]operador. Se encuentra muy poco al respecto en Internet, el único digno de mención ...
Retrofit2 Recursión de la cola con RxJava / RxAndroid
Realmente estoy tratando de acostumbrarme a usarRetrofit conRxJava / RxAndroid. He hecho esto usando normalRetrofit2 Callback método en una aplicación anterior sin el uso deReactive Programming Y funcionó bien. Entonces, aquí está. necesitoTail ...
¿Cómo obtener la url de solicitud en la actualización 2.0 con rxjava?
Estoy tratando de actualizar a Retrofit 2.0 y agregar RxJava en mi proyecto de Android. Estoy haciendo una llamada API y quiero recuperar la url y con los datos de respuesta en sqlite como caché Observable<MyResponseObject> apiCall(@Body body);Y ...
Buscando una manera limpia de manejar errores en RxJava
Estoy aprendiendo RxJava y he visto en muchos lugares que un error puede manejarse de esta manera: repository.getById(10).subscribe(new Action1<User>() { @Override public void call(User user) { //Do something } }, new Action1<Throwable>() { ...
Llame a otra llamada de actualización en emisión de sujeto
Tengo una siguiente clase: public class SessionStore { Subject<Session, Session> subject; public SessionStore() { subject = new SerializedSubject<>(BehaviorSubject.create(new Session()); } public void set(Session session) { ...