Resultados de la búsqueda a petición "rx-java"
¿Cómo implementar observeLatestOn en RxJava (RxScala)?
Estoy tratando de implementar elObserveLatestOn [https://social.msdn.microsoft.com/Forums/en-US/bbcc1af9-64b4-456b-9038-a540cb5f5de5/how-do-i-ignore-allexceptthelatest-value-when-my-subscribe-method-is-running?forum=rx>] operador en RxJava (en ...
Entregue el primer elemento de inmediato, 'rebote' siguientes elementos
Considere el siguiente caso de uso: necesita entregar el primer artículo lo antes posibleNecesitarrebotar siguientes eventos con tiempo de espera de 1 segundoTerminé implementando un operador personalizado basado enOperatorDebounceWithTime luego ...
Use RxJava y Retrofit para iterar a través de la lista y aumentar los resultados basados en subconsultas
Estoy usando la actualización y siento que rxjava (con retrolambda) sería una buena opción para el siguiente flujo: obtener una lista de widgets (http)para cada widget a) obtener una lista de artículos (http) para el tipo de widget dado b) ...
Cadena de dos observables de actualización con RxJava
Quiero ejecutar 2 llamadas de red una tras otra. Ambas llamadas de red devuelven Observable. La segunda llamada usa datos del resultado exitoso de la primera llamada, el método en el resultado exitoso de la segunda llamada usa datos ...
RxJava: "java.lang.IllegalStateException: ¡solo se permite un suscriptor!"
Estoy usando RxJava para calcular la correlación automática normalizada sobre algunos datos del sensor en Android. Por extraño que parezca, mi código arroja una excepción ("java.lang.IllegalStateException: ¡solo se permite un suscriptor!") Y no ...
Cómo manejar el error auth0 403 sin agregar código específico en todas partes (Retrofit / okhttp / RxAndroid)
Estoy usando Auth0, que me da un JWT (json web token) y un código de actualización. Utilizo este JWT en los encabezados http para comunicarme con mi backend. Puede suceder que el servidor me dé un403, cuando decide que el JWT ha expirado. En ...
Cómo cancelar la tarea con retrofit y rxjava
Tengo descanso api. @Get("/serveraction") public Observable<String> myRequest(@Query("Data") String data);Lo sé, okhttp tiene una funcionalidad de cancelación (por objeto de solicitud, por etiqueta), pero no sé cómo usarlo con retrofit y rxjava. ...
Reintento de RxJava basado en lógica
Este es el caso, tengo una API llamada usign Retrofit que podría fallar debido a un error de red. Si falla, mostraremos un mensaje de error con un botón de reintento. Cuando el usuario presiona el botón de reintento, necesitamos volver a intentar ...
RxJava - Just vs From
Estoy obteniendo el mismo resultado cuando usoObservable.just vsObservable.from en el siguiente caso: public void myfunc() { //swap out just for from here and i get the same results,why ? Observable.just(1,2,3).subscribe(new ...
¿Cómo devolver valor con RxJava?
Consideremos esta situación. Tenemos alguna clase que tiene un método que devuelve algún valor: public class Foo() { Observer<File> fileObserver; Observable<File> fileObservable; Subscription subscription; public File getMeThatThing(String id) { ...