Resultados de la búsqueda a petición "rx-java2"
¿Por qué la operación de eliminación de sala (con RxJava) da un error de subproceso de interfaz de usuario incluso especificando subproceso de suscripción diferente?
Así que simplemente, el DAO @Query("DELETE FROM Things WHERE someIdOfTheThing IN (:listOfId)") abstract fun deleteThings(listOfId: MutableList<String>): Maybe<Int>uso mDisposables.add(mThingsDao ...
Flowable concatMapSingle sin captación previa para ignorar los clics hasta que finalice el procesamiento
Quiero manejar los clics de tal manera que se ignoren siempre que esté procesando algún clic que se haya producido. Pensé que podría hacerlo utilizando la contrapresión, como esta: private val clicks = PublishProcessor.create<Unit>() // ... ...
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 ...
múltiple solicitud de API con retrofit y rx java
Soy nuevo en Android y tengo un escenario en el que quiero obtener datos de múltiples API. Supongamos que api_a, api_b, api_c, api_d. Estas API son independientes entre sí, pero quiero mostrar los datos de estas API en una vista mixta de ...
El resultado de la suscripción no se usa
Hoy he actualizado a Android Studio 3.1, que parece haber agregado algunas comprobaciones de pelusas más. Una de estas comprobaciones de pelusa es para RxJava2 de un disparosubscribe() llamadas que no están almacenadas en una variable. Por ...
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 ...
¿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 ...
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 ...
¿Cuándo usar RxJava en Android y cuándo usar LiveData de Android Architectural Components?
No obtengo la razón para usar RxJava en Android y LiveData de Android Architectural Components. Sería realmente útil si los casos de uso y las diferencias entre ambos se explican junto con un ejemplo de ejemplo en forma de código que explica las ...
¿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 ...