Resultados de la búsqueda a petición "rx-java"
EventBus / PubSub vs (extensiones reactivas) RX con respecto a la claridad del código en una sola aplicación de subprocesos
Actualmente, estoy usando un EventBus /PubSub [http://en.wikipedia.org/wiki/Publish%E2%80%93subscribe_pattern]arquitectura / patrón con Scala (y JavaFX) para implementar una aplicación simple de organización de notas (algo así como un cliente ...
Producto cartesiano en RxJava
¿Es posible obtener el producto cartesiano de dos Observables en rxjava? Algo como esto: A -> 1,2,3 B -> a,b A x B -> (1, a), (1, b), (2, a), (2, b), (3, a), (3, b)
Kotlin y RxJava: ¿por qué mi Single.zip () no se está compilando?
Me estoy volviendo un poco loco aquí. Estoy tratando de crear unObservable<BigDecimal> función de extensión (contra RxJava 2.x) para emitir el promedio de las emisiones, pero obtengo un error de compilación con elSingle.zip() función. ¿Alguien ...
RxJava: encadenamiento de solicitudes y actualización de la interfaz de usuario
El problema que tengo es este. Necesito ejecutar un par de solicitudes al servidor. Cada solicitud siguiente depende del resultado de la anterior. Se ven así (abreviados): Observable<FileUploadResponse> obsFile = ...
Obtenga una instantánea de GoogleMap en segundo plano
Estoy tratando de obtener la instantánea de un GoogleMap (de MapView) en segundo plano, devolverlo con una devolución de llamada y mostrarlo en un ImageView. Mientras hago esto, trato de hacer que la parte de la instantánea sea independiente del ...
Reanudación fluida convertida a datos en vivo después de la rotación de la pantalla
Digamos que tengo una actividad como esta: public class TestActivity extends AppCompatActivity { @Override public void onCreate(@Nullable Bundle savedInstanceState) { super.onCreate(savedInstanceState); final TextView countdown = ...
¿Cómo crear un Android observable desde el evento OnClick?
Soy nuevo en programación reactiva. Así que tengo problemas al crear una transmisión desde un evento, como onClick, ontouch ... Alguien puede ayudarme a resolver este problema. Gracias.
¿Por qué mi temporizador Observable nunca se llama?
En Android, he escrito unObservable que debería llamarse una vez después de 2000 ms, pero que nunca se llama. Observable.timer(2000, TimeUnit.MILLISECONDS) // wait 2000 ...
¿Cómo manejar la paginación con RxJava?
Estoy buscando convertir mi aplicación de Android para usar Rxjava para solicitudes de red. Actualmente accedo a un servicio web similar a: getUsersByKeyword(String query, int limit, int offset)Según tengo entendido, los Observables son una ...
¿Cómo esperar varias llamadas asíncronas anidadas usando RxJava-Android?
Soy nuevo en RxJava, aquí está mi caso, enviar solicitud A y obtendráList<A> espaldapara cada A, envíe la solicitud AA y recuperará AA, vinculará A y AA y luegohay B & BB con lógica similarhacer algo solo después de completar todas las ...