Resultados de la búsqueda a petición "rx-java"
¿Cuál es la forma correcta de darse de baja de Single?
Quiero hacer algo después de un breve retraso: public void notifyMe() { Single .timer(500, TimeUnit.MILLISECONDS) .subscribeOn(Schedulers.io()) .subscribe(ignore -> service.notifyMe())); }Ahora tengo una advertencia:"The result of subscribe is ...
La recopilación de observables en una lista no parece emitir la colección de inmediato
Estoy usando RxJava para recopilar esencialmente la lista de Observables emitidos individualmente y combinarlos en una lista de Observables (esencialmente lo contrario de flatMap). Aquí está mi código: // myEvent.findMemberships() returns an ...
RestAPI asíncrono con RxJava / Jersey2. Enhebrar preguntas?
Estamos en el proceso de creación de prototipos de una API REST mediante programación reactiva. Como se muestra en el diagrama, mantenemos 3 capas iguales a las que usamos en nuestros diseños de API de sincronización anteriores; ...
Android: sondeo de un servidor con Retrofit
Estoy construyendo un juego de 2 jugadores en Android. El juego funciona por turnos, por lo que el jugador 1 espera hasta que el jugador 2 hizo su entrada y viceversa. Tengo un servidor web donde ejecuto una API con ...
RxJava + actualización, obtenga una Lista y agregue información adicional para cada elemento
Estoy jugando con RXJava, actualización en Android. Estoy tratando de lograr lo siguiente: Necesito sondear periódicamente una llamada que me da un Observable> (Desde aquí podría hacerlo) Una vez que obtenga esta lista, quiero iterar en cada ...
¿Cómo componer Observables para evitar las devoluciones de llamada anidadas y dependientes?
Eneste blog [https://web.archive.org/web/20150712091623/http://benjchristensen.com:80/2013/05/01/functional-reactive-in-the-netflix-api-with-rxjava/] , El daesta [https://gist.github.com/benjchristensen/4677544](copie / pegue el siguiente código) ...
¿Cuál es el propósito de doOnNext (...) en RxJava
¿Cuándo deberíamos usardoOnNext () [http://reactivex.io/RxJava/javadoc/rx/Observable.html#doOnNext(rx.functions.Action1)] desde Observable en lugar de solo en Next ()?
Secuencia de solicitudes combinadas de RxJava
El problemaTengo dos Apis. Api 1 me da una lista de elementos y Api 2 me da información más detallada para cada uno de los elementos que obtuve de Api 1. La forma en que lo resolví hasta ahora resulta en un mal rendimiento. La preguntaSolución ...
RxJava buffer hasta cambiado
Tengo un observable que emite una gran cantidad de datos como [1,1,1,2,2,2,3,3,1,1,5,5 ......] En RxJava podemos usardistinctUntilChanged () [http://reactivex.io/documentation/operators/distinct.html]para obtener elementos distintos hasta que ...
Listas de unión de Android RxJava
Tratando de entender todas esas cosas de RxJava. Estaba haciendo el siguiente ejemplo: private Observable<List<String>> query1() { List<String> urls = new ArrayList<>(); urls.add("1"); urls.add("2"); urls.add("3"); urls.add("4"); return ...