Resultados de la búsqueda a petición "rx-java"
Operador RxJava que emite si es diferente del último
¿Hay un operador que emite elementos si el elemento a emitir no es igual al último elemento emitido?
Ejecute el método vacío en segundo plano
Quiero ejecutar un método en segundo plano usando rxjava. No me importa el resultado. void myHeavyMethod() { (...) }Hasta ahora, la única solución que tengo es modificar el tipo de retorno a, p.boolean. boolean myHeavyMethod() { (...) return ...
RxBindings For Spinner?
Soy nuevo Android y rxjava. He visto muchos ejemplos en los que escuchamos eventos con enlaces rx. como esto RxView.clicks(b).subscribe(new Action1<Void>() { @Override public void call(Void aVoid) { // do some work here } ...
Prueba de Android RxJava 2 JUnit - getMainLooper en android.os.Looper no se burló de RuntimeException
Me encuentro con una RuntimeException cuando intento ejecutar pruebas JUnit para un presentador que está usandoobserveOn(AndroidSchedulers.mainThread()). Como son pruebas JUnit puras y no pruebas de instrumentación de Android, no tienen acceso a ...
RxJava 2 anula el planificador de E / S en la prueba unitaria
Estoy tratando de probar el siguiente código RxKotlin / RxJava 2: validate(data) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .flatMap { ... }Estoy intentando anular los planificadores de la siguiente manera: // Runs ...
Rx Java Android: cómo convertir este bloque de devolución de llamada a Observer
Estoy tratando de cargar un archivo a través del SDK de Android S3 de Amazon. He usado RX Java un poco, pero no estoy seguro de cómo convertir este método en un método que devuelva un Observable porque quiero encadenar el resultado de este método ...
Patrón RxJava para solicitar un Observable remoto con un caché temporal
El caso de uso es este: quiero almacenar temporalmente en caché la última respuesta Observable costosa emitida, pero después de que caduque, volver a la fuente costosa Observable y almacenarla en caché nuevamente, etc. Un escenario de caché de ...
Cómo procesar los primeros n elementos y permanecer uno de manera diferente en una secuencia observable
por ejemplo, dada una secuencia de un cierto número (m) de números (m1, m2, m3, m4, m5, m6 ...), y aplicar una transformación (2 * i) a los primeros n elementos (n puede ser menor, igual o mayor que m), aplique otra transformación (3 * i) a ...
¿Cuál es la diferencia entre Observable, Completable y Single en RxJava?
¿Alguien puede explicar la diferencia entre Observable, Completable y Single en RxJava con ejemplos claros? ¿En qué escenario usamos uno sobre los otros?
Cómo encadenar dos Completables en RxJava2
Tengo dos Completables. Me gustaría hacer el siguiente escenario: si el primer Completable llega a onComplete, continúe con el segundo Completable. Los resultados finales estarían en Completo del segundo Completable. Así es como lo hago cuando ...