rx-java

Estoy trabajando en redes para mi aplicación. Así que decidí probar el Retrofit de Square. Veo que apoyan simple Callback @ ... lo de Jake Wharton U2020. Pero esencialmente la pregunta sigue siendo la misma-cuando se debe utilizar una forma o la ¿otro?

¿Cuándo se usa map vs flatMap en RxJava? Digamos, por ejemplo, que queremos asignar Archivos que contienen JSON en Cadenas ... guna de las mejores prácticas en esto flotando alrededor y tengo curiosidad por saber cómo se está utilizando en la práctica.

La definición de switchmap de rxjava doc es bastante vaga y enlaza con la misma página que flatmap. ¿Cuál es la diferencia entre los dos operadores?

¿Son los flujos de Java 8 similares a los observables de RxJava? Java 8 definición de flujo: Las clases en el nuevo paquete java.util.stream proporcionan una API de flujo para admite operaciones de estilo funcional en flujos de elementos.

Estoy tratando de actualizar a Retrofit 2.0 y agregar RxJava en mi proyecto de Android. Estoy haciendo una llamada a la api y ... y podíamos obtener el estado haciendo: error.getResponse().getStatus() ¿Cómo se hace esto con Retrofit 2.0 usando RxJava?

Estoy tratando de descifrar la siguiente función: Subscription getCar(id, Observer<Car> observer) { return getCarD ... zo parecer como un suscriptor. El javadoc for subscriber dice que implementa observer y subscription. Estoy muy confundido.

He estado mirando el nuevo rx java 2 y no estoy muy seguro de entender la idea de backpressure más... Soy consciente de que ... ministrar buffer? O tal vez desde el otro lado, ¿qué ventajas me dan backpressure a favor de la gestión y manejo del consumo?

Estoy usando rxjava en mi aplicación Android para manejar solicitudes de red de forma asíncrona. Ahora me gustaría volver a i ... que el retraso no se aplicara después de un error, sino antes de un reintento (pero no antes del primer intento, obviamente).

Estoy encadenando operaciones asincrónicas usando RxJava, y me gustaría pasar alguna variable aguas abajo: Observable .f ... access data1 here ? return op2(data2); }) Parece un patrón común, pero no pude encontrar información al respecto.

Ejemplos sobre cómo usar CompositeDisponible o Desechable en RxJava2. En RxJava 1, había suscripción de composiciones, pero e ... no está presente en RxJava2, hay algo CompositeDisposable en RxJava2. Cómo usar CompositeDisponible o desechable en RxJava2.

Voy a enviar un método get simple a mi servidor(es Rails app) y obtener el resultado usando RxJava y Retrofit. Lo que hice es ... ter-rxjava:2.0.2' compile 'com.squareup.retrofit2:converter-gson:2.0.0' compile 'com.google.code.gson:gson:2.4' }

Necesito ayuda para implementar llamadas asíncronas paralelas en RxJava. He recogido un caso de uso simple en el que la PRIME ... iba debe verse más verticalmente apilado. Las llamadas a comentarios e imágenes deben estar en paralelo Gracias anand raman

Parece que en cada iteración de Java para las últimas versiones principales, hay consistentemente nuevas formas de administra ... dos bibliotecas? ¿Por qué alguien usaría la biblioteca Java 9 Flow sobre la mucho más diversa biblioteca RxJava o viceversa?

Estoy teniendo muchos problemas para entender el operador zip en RxJava para mi proyecto Android. Problema Necesito poder en ... magino. Estoy buscando a alguien que responda cómo se puede hacer esto conceptualmente con un poco de código psuedo. Gracias

Estoy luchando para implementar algo que asumí que sería bastante simple en Rx. Tengo una lista de elementos, y quiero que c ... Pero lo que esperaría ver algo como esto: 174ms [5] 230ms [2] 285ms [1] 345ms [3] 399ms [4] ¿Qué estoy haciendo mal?

Estoy confundido acerca de la diferencia entre EventBus y RxJava en Android. Necesito implementar uno de ellos para mi proble ... alizar su estado. Además, leí que EventsBus se ha vuelto obsoleto sobre RxJava y no se si esta información es verdadera o no.

Dada una lista de autos (List<Car> cars), puedo hacer: Observable.just(cars); //returns an Observable that emits one ... List<Car> a una secuencia de Observable<Car>? Algo así como un from sin parámetros Obserable.just(cars).from()

Tengo la Lista de SourceObjects y necesito convertirla a la Lista de ResultObjects. Puedo obtener un objeto a otro usando el ... onvertFromSource(srcObj)); } } Pero estaré muy agradecido a alguien que pueda mostrar cómo hacer lo mismo usando RxJava.

Estoy recibiendo un error IllegalStateException en la biblioteca Rx y no sé exactamente dónde está la raíz del problema, si e ... rvices.common.BackgroundPriorityRunnable.run(BackgroundPriorityRunnable.java:13) at java.lang.Thread.run(Thread.java:856)

¿Cuál es el beneficio de usar Retrofit en combinación con Rxjava?