RxJava - Extensiones reactivas para JVM - una biblioteca para componer programas asincrónicos y basados en eventos usando secuencias observables para Java VM.
Estoy trabajando en redes para mi aplicación. Así que decidí probar Square's Retrofit . Veo que soportan simplesCallback @GET("/user/{id}/photo") void getUserPhoto(@Path("id") int id, Callback<Photo> cb); y de RxJava Observable @GET("/user/{id}/photo") Observable<Photo>...
En RxJava hay 5 programadores diferentes para elegir: inmediata () : crea y devuelve un Programador que ejecuta el trabajo inmediatamente en el hilo actual. trampoline () : crea y devuelve un Programador que pone en cola el trabajo en el hilo actual para que se ejecute después de que se...
Me gustaría saber la diferencia entre CompletableFuture, Futurey Observable 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--- similar a CompletableFutureotros beneficios (no estoy...
¿Cuándo usas mapvs flatMapen RxJava ? Digamos, por ejemplo, que queremos asignar archivos que contienen JSON en cadenas que contienen el JSON: Usando map, tenemos que lidiar con el de Exceptionalguna manera. ¿Pero cómo?: Observable.from(jsonFile).map(new Func1<File, String>() { @Override...
La definición de rxjava doc de switchmap es bastante vaga y se vincula a la misma página que flatmap. ¿Cuál es la diferencia entre los dos
¿Las secuencias de Java 8 son similares a las observables de RxJava? Definición de flujo de Java 8: Las clases en el nuevo java.util.streampaquete proporcionan una API Stream para admitir operaciones de estilo funcional en secuencias de
He estado mirando nuevo rx java 2 y no estoy muy seguro de entender la idea de backpressuremás ... Soy consciente de que tenemos Observableque no tiene backpressureapoyo y Flowableque lo tiene. Entonces, basado en el ejemplo, digamos que tengo flowablecon interval: Flowable.interval(1,...
¿Alguien puede explicar la diferencia entre Observable, Completable y Single en RxJava con ejemplos claros? ¿En qué escenario usamos uno sobre los
Estoy intentando actualizar a Retrofit 2.0 y agregar RxJava en mi proyecto de Android. Estoy haciendo una llamada a la API y quiero recuperar el código de error en caso de una respuesta de error del servidor. Observable<MyResponseObject> apiCall(@Body body); Y en la llamada...
Voy a enviar un método get simple a mi servidor (es la aplicación Rails) y obtendré el resultado usando RxJava y Retrofit. Lo que hice fue: Mi interfaz: public interface ApiCall { String SERVICE_ENDPOINT = "https://198.50.214.15"; @GET("/api/post") io.reactivex.Observable<Post>...
Estoy usando rxjava 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 que haya pasado un cierto tiempo. ¿Hay alguna forma de usar retry () en un Observable pero reintentar solo...
TL; DR Cómo convertirTask.whenAll(List<Task>) en RxJava? Mi código existente usa Bolts para crear una lista de tareas asincrónicas y espera hasta que todas esas tareas terminen antes de realizar otros pasos. Esencialmente, genera un List<Task>y devuelve uno Taskque se marca como...
¿Cuáles son los beneficios de usar Schedulers.newThread()frente Schedulers.io()a Retrofituna solicitud de red? He visto muchos ejemplos que usan io(), pero quiero entender por qué. Situación de ejemplo: observable.onErrorResumeNext(refreshTokenAndRetry(observable))
Estoy tratando de descifrar la siguiente función: Subscription getCar(id, Observer<Car> observer) { return getCarDetails(id, new Observer<CarDetails> { @Override onNext(CarDetails details) { observer.onNext(details.getCar()); } }); } Obtuve una buena introducción a rxjava de...