Resultados de la búsqueda a petición "rx-java2"
Usando RxJava 2 y Retrofit 2, problema de versión del adaptador
He agregado un nuevo módulo de biblioteca al módulo de aplicación existente en Android Studio. La principal diferencia fue agregar RxJava 2 y Retrofit 2. Después de actualizar build.gradle del nuevo módulo, comencé a recibir el siguiente ...
Maneje la respuesta vacía con retrofit y rxjava 2.x
Cuando usaba rxjava 1.x solía volverObservable<Void> para manejar la respuesta vacía de la modificación: @POST( "login" ) Observable<Void> getToken( @Header( "Authorization" ) String authorization, @Header( "username" ) String username, @Header( ...
¿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?
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 ...
RxAndroid y Retrofit: no se puede crear el adaptador de llamada para io.reactivex.Observable <retrofit2.Response <okhttp3.ResponseBody >>
Estoy intentando usar rxJava, rxAndroid, Retrofit2 y OkHTTP3 para descargar un archivo desde un punto final de URL. Mi código no puede crear el adaptador de llamada para un "Observable <retrofit2.Response <okhttp3.ResponseBody >>". Estos métodos ...
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 ...
Observable.combineLa última inferencia de tipos en kotlin
Estoy usando RxJava2, Kotlin-1.1 junto con RxBindings en mi proyecto. Tengo una pantalla de inicio de sesión simple con el botón 'iniciar sesión' deshabilitado de forma predeterminada, quiero habilitar el botón solo cuando los campos de edición ...
¿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?
¿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 ...