Resultados de la búsqueda a petición "rx-java"
InterruptedIOException mientras usa Retrofit2 con rx cuando reintenta
Estoy usando retrofit 2 con rx-android Tengo una lógica de reintento bastante compleja,que funciona parcialmente. Corté el código irrelevante para simplificarlo. Aquí está: public class RetryWithDelay implements Func1<Observable<? extends ...
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 burlarse de los servicios con Retrofit 2.0 y la nueva clase MockRetrofit?
Usando Retrofit 1 solíamos burlarnos de los servicios web y simular la latencia de la red de la siguiente manera: MockRestAdapter mockRestAdapter = MockRestAdapter.from(restAdapter); return mockRestAdapter.create(MyService.class, new ...
¿Cómo ejecutar 2 consultas secuencialmente en un Android RxJava Observable?
Quiero ejecutar 2 tareas asincrónicas, una seguida de la otra (secuencialmente). He leído algo sobre ZIP o Flat, pero no lo entendí muy bien ... Mi propósito es cargar los datos de un SQLite local, y cuando finaliza, llama la consulta al ...
Reino, operaciones de red, suscripción y observación en diferentes hilos con RxJava
Necesito : Obtener algunos datos de una API en un hilo de fondoMostrar los datos en la interfaz de usuarioGuardar en el reino. fetchItemsFromServer().subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()).subscribe(new ...
RxJava; Cómo emitir observables sincrónicamente
Quiero emitir sincrónicamente dos objetos Observables (que son asíncronos), uno tras otro donde devuelve elprimero Objeto observable emitido. Si el primero falla, no debería emitir el segundo. Supongamos que tenemos un Observable que inicia ...
¿Cómo analizar una respuesta JSON cuando se usa la modificación cuando la respuesta es a veces un objeto y otras una matriz?
Estoy usando Retrofit para obtener una respuesta JSON. Aquí hay partes de mi implementación: @GET("/api/report/list") Observable<Bills> listBill(@Query("employee_id") String employeeID);y la clase Bills es - public static class Bills { ...
Diferencia entre CompletableFuture, Future y RxJava's Observable
Me gustaría saber la diferencia entreCompletableFuture,Future yObservable RxJava. Lo que sé es que todos son asincrónicos pero Future.get() bloquea el hilo CompletableFuture da los métodos de devolución de llamada RxJava Observable --- ...
Combine RxTextView Observable y Retrofit Observable
Como ejemplo para comenzar a usar RxAndroid, estoy tratando de implementar un cuadro de búsqueda que active una llamada de descanso cuando los usuarios inserten algo. Hasta ahora tengo dos partes de trabajo. El primero observando el ...
Cómo detener y reanudar los tics de emisión Observable.interval
Esto emitirá un tic cada 5 segundos. Observable.interval(5, TimeUnit.SECONDS, Schedulers.io()) .subscribe(tick -> Log.d(TAG, "tick = "+tick));Para detenerlo puedes usar Schedulers.shutdown();Pero luego todos los Programadores se detienen y no ...