Resultados de la búsqueda a petición "rx-java2"

1 la respuesta

¿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?

2 la respuesta

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 ...

2 la respuesta

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 ...

1 la respuesta

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 ...

4 la respuesta

¿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 ...

1 la respuesta

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 ...

2 la respuesta

¿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 = ...

8 la respuesta

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 ...

3 la respuesta

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: ...

1 la respuesta

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 ...