Resultados de la búsqueda a petición "rx-java"
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 ...
Las funciones onNext y onComplete de mi suscriptor no se ejecutan cuando llamo a onNext dentro de mi clase FlowableOnSubscribe
En un proyecto de Android que usa RxJava 2, creo unFlowable así en elonCreate de mi actividad inicial: Flowable.create(new MyFlowableOnSubscribe1(), BackpressureStrategy.BUFFER) .doOnComplete(new MyAction()) ...
¿Suscribirse con Vs suscribirse en RxJava2 (Android)?
¿Cuándo llamar al método subscribeWith en lugar de simple suscribirse? ¿Y cuál es el caso de uso? compositeDisposable.add(get() .observeOn(AndroidSchedulers.mainThread()) .subscribeOn(Schedulers.io()) ...
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?
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 ...
Cómo proporcionar contexto con Dagger2
Estoy aprendiendo Android y estoy siguiendo algunas guías para Retrofit2 con RxJava y Dagger2. Ahora no quiero manejar ningún caso de conexión a Internet. He encontrado estoresponder [https://stackoverflow.com/a/40667193/5058677], que parece ...
Kotlin cuádruple, quíntuple, etc. para la desestructuración
Estoy buscando una forma limpia de crear objetos desestructurables en línea.kotlin.Pair ykotlin.Triple cubren muchos casos de uso, pero a veces hay más objetos que se deben pasar. Un caso de uso de muestra es el de RXzip función, donde los ...
Retrofit + Rxjava tarda mucho en invocar onError cuando falla la conexión del servidor
Estoy usando Retrofit + Rxjava para obtener una lista de entidades del servidor, según mi diseño cuando la tarea falla, primero verifica la conexión a Internet y luego verifica la conexión al servidor endoOnError método deObservable. Cuando el ...
rxjava: ¿Puedo usar retry () pero con retraso?
Estoy usando rxjava en mi aplicación de Android para manejar solicitudes de red de forma asincrónica. Ahora me gustaría volver a intentar una solicitud de red fallida solo después de que haya pasado un cierto tiempo. ¿Hay alguna forma de usar ...
RxJava: ¿cómo componer múltiples Observables con dependencias y recopilar todos los resultados al final?
Estoy aprendiendo RxJava y, como mi primer experimento, intento reescribir el código en el primerrun() método eneste codigo [https://gist.github.com/benjchristensen/4671081](citado enEl blog de ...