Preguntas con etiqueta "rx-java2"

0

Fluida subscríbete obtiene una lista vacía después de la inserción de registros

Yo soy la recuperación de los datos de Room de la base de datos de usar MVVM RxJava patrón. Fragment pide a los viewModel de datos y subscribes withit. ViewModel obtiene los datos desde el almacenamiento local y devuelve a Fragment y por su parte tam...
1

Cómo obtener onComplete con Sala de Fluidos<List<Item>>?

Tengo una aplicación para Android usando espacio para guardar mis favoritos. Aquí está mi DAO : @Query("SELECT * FROM favorites ORDER BY lastConsultation DESC") fun getAll() : Flowable<List<Favorite>> Quiero usar Fluidos para habilita...
0

RxAndroid: Mockito - Cómo probar el código escrito dentro de un observador

Tengo el siguiente código, en mi opinión, modelo: fun fetchShopInformation() { progress.postValue(true) shopUseCase.execute(object: DisposableObserver<Result<Shop>>(){ override fun onComplete() { ...
1

Cómo Observable es creado en retrofit sin llamarlo de programador?

Estoy trabajando en rx-java y de readaptación, y tengo algunas consultas relacionadas con ella.Yo no soy capaz de entender que cuando llamamos a continuación el código, a continuación, cómo Observable(Observable) es creada ? De acuerdo, a mi entender...
0

La carga de la imagen de la API con @solicitud GET Glide

Cómo puedo cargar una imagen desde un API método que utiliza @GET y volver a mí una foto en un ImageView usando Glide? Estoy usando un VMMV Arquitectura, así que tengo mi depósito y devolución de las cadenas de Observables RxJava. Yo intente utiliz...
1

¿Cómo puedo obtener el error de ViewModel en la Llamada a la API en la Actividad?

Cuando yo uso el ViewModel en Android, he utilizado dos MutableLiveData objetos en mi clase ViewModel. var imageList: MutableLiveData<List<HitsItem>> = MutableLiveData() var errorMessage: MutableLiveData<String> = MutableLiveData()...
0

Cómo hacer el tiempo de espera de operador de fuego excepción de una vez en RxJava2 (RxJava3) de la cadena antes de reintentar

Yo estoy tratando de extender la funcionalidad de mi personalizados FlowableTransformer que yo uso para condicionalmente cambiar de un Flowable a otro, devuelto por siempre Function<T, Flowable<R>>, es decir, en mi switchFunction I enviar...
0

La implementación de un API de Flujo de Procesador utilizando rxjava

Tengo curiosidad por cómo Java API de flujo de lazos con RxJava, y en particular, cómo puedo escribir un simple Procesadores aprovechando RxJava. Digamos que usted tiene una simple transformación, el mapeo de las Cadenas de sus longitudes: Function...
0

Impedir que el código de suscripción de la ejecución cuando el sujeto se inicializa

En este código: class RequestNewPasswordFragment { override fun onViewCreated(view: View, savedInstanceState: Bundle?) { super.onViewCreated(view, savedInstanceState) btnRequestNewPassword.setOnClickListener { view....
1

Lo Sujeto emite sólo los elementos después de la suscripción

En rxJava, quiero un sujeto a empezar a emitir "nuevos" elementos después de suscribir el método es llamado. El más cercano que he encontrado a esto es PublishSubject pero los docs del estado las siguientes: PublishSubject emits to an observer on...
1

RxJava2 Fluida para distinguir el último elemento

Quiero proceso de Flowable en lotes, y a la manija de la última hornada de manera diferente. Existe una mejor manera de utilizar un AtomicReference para almacenar en caché el lote anterior y el proceso de la última hornada en onComplete()? Ato...