Resultados de la búsqueda a petición "rx-java"
Flujo correcto en RxJava con Retrofit y Realm
Estoy implementando API de red con la combinación de RxJava y Retrofit, y uso Realm como mi base de datos. Lo tengo funcionando bastante bien, pero me pregunto si es el enfoque correcto y el flujo de eventos. Entonces, aquí ...
demora rxjava: ¿Cómo obtener demora variable en cada elemento emitido desde una lista?
Quiero tener retrasos personalizados entre cada elemento emitido desde una lista observable en función de los elementos mismos. Digamos que tenemos una lista como (item, delay): [("item1", 2),("item2", 1),("item3", 2),("item4", 3),("item5", ...
¿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 ...
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 ...
Kotlin: ¿Qué significa "return @"?
Estoy usando RxJava en uno de mis proyectos, convertí una de mis clases a Kotlin usando el complemento de Android Studio y en uno de mapflatMap lambda (Func1 en java), los retornos intermedios se parecen a los siguientes@Func1. No tengo idea de ...
Manejo nulo en RxJava2
Con el próximoLanzamiento de RxJava2 [https://github.com/ReactiveX/RxJava/tree/2.x]Uno de los cambios importantes es quenull ya no se acepta como elemento de transmisión, es decir, el siguiente código arrojará una ...
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>() { ...
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 ...
RXJava: haga que un observable pausable (con búfer y ventana, por ejemplo)
Quiero crear observables que hagan lo siguiente: almacenar todos los elementos en el búfer, mientras están en pausaemiten inmediatamente elementos, mientras no están en pausael disparador de pausa / reanudación debe provenir de otro ...
RxJava + Retrofit -> BaseObservable para llamadas API para el manejo centralizado de respuestas
Soy nuevo en RxJava, así que perdóname si esto suena demasiado novato :-). A partir de ahora tengo un CallbackClass abstracto que implementa la devolución de llamada Retofit. Allí capto los métodos "onResponse" y "onError" de Callback y manejo ...