Resultados de la búsqueda a petición "rx-java2"
Android Dagger2 + OkHttp + Error de ciclo de dependencia de actualización
Hola, estoy usandoDagger2, Retrofit yOkHttp y estoy enfrentando un problema de ciclo de dependencia. Al proporcionarOkHttp : @Provides @ApplicationScope OkHttpClient provideOkHttpClient(TokenAuthenticator auth,Dispatcher dispatcher){ return new ...
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: ...
¿Cuál es la forma correcta de darse de baja de Single?
Quiero hacer algo después de un breve retraso: public void notifyMe() { Single .timer(500, TimeUnit.MILLISECONDS) .subscribeOn(Schedulers.io()) .subscribe(ignore -> service.notifyMe())); }Ahora tengo una advertencia:"The result of subscribe is ...
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 ...
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 ...
¿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 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?
¿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 = ...
Es RxJava una buena opción para ramificar flujos de trabajo?
Estoy usando RxJava para procesar algunas notificaciones que extraemos de una cola. RxJava parecía funcionar bien con un flujo de trabajo simple, ahora con nuevos requisitos, el flujo está creciendo en complejidad con más ramas (vea la imagen a ...
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 ...