Resultados de la búsqueda a petición "rx-java2"
¿Cómo suscribir varios suscriptores a Observable o Flowable?
En el ejemplo de Hello World hay un suscriptor public static void main(String[] args) { Flowable.just("Hello world").subscribe(System.out::println); }¿Cómo hacer dos o más?
Vuelva a intentar una llamada con Retrofit 2 y RxJava2 después de mostrar un cuadro de diálogo
Llamo a una API usando Retrofit 2 y RxJava2. Si falla una llamada, en algunos casos (por ejemplo, sin conexión a Internet), quiero mostrar un diálogo de error al usuario y dejar que vuelva a intentarlo. Como estoy usando RxJava, estaba pensando ...
RxJava2 observable tomar tiros UndeliverableException
Según tengo entendido RxJava2values.take(1) crea otro Observable que contiene solo un elemento del Observable original. CualNO DEBElanzar una excepción ya que se filtra por el efecto detake(1) como sucedió en segundo lugar. como en ...
Sujeto RxJava con contrapresión: solo deje que el último valor se emita una vez que el flujo descendente haya terminado de consumir
Tengo un PublishSubject que llamaonNext() en algún evento de IU. El suscriptor generalmente tarda 2 segundos en completar su trabajo. Necesito ignorar todas las llamadas aonNext() excepto el último mientras el suscriptor está ocupado. Intenté lo ...
¿Cuál es la diferencia entre llaves y llaves normales en RxJava con Kotlin?
No entiendo la verdadera diferencia entre las llaves y las llaves normales en Kotlin cuando uso RxJava. Por ejemplo, tengo el siguiente código que funciona como se ...
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 ...
¿Cuál es la diferencia entre RxJava 2 Cancelable y Desechable?
Quiero crear unObservable desde la vista, haga clic en el oyente usando RxJava 2. Comencé desde la implementación más simple (no uso lambdas aquí para mostrarle diferentes tipos en este método): Observable<View> viewObservable = ...
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 ...
Error de RxJavaPlugins No se encontró la clase "com.google.devtools.build.android.desugar.runtime.ThrowableExtension"
Después de actualizar Android Studio 3.0 Beta 1, aparece el siguiente error. Cuando degradé el error desapareció. Studio Build: Android Studio 3.0 Beta 1 Versión de Gradle Plugin: 'com.android.tools.build:gradle:3.0.0-beta1' Versión de Gradle: ...
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 ...