Resultados de la búsqueda a petición "rx-java2"
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 ...
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 ...
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 ...
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 ...
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>() // ... ...
¿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 ...