Articles of rx java2

RxJava2 + Retrofit pantalla negra en request de datos

Estoy enfrentando un problema con una aplicación de Android mientras trato de recuperar algunos datos Api utilizando RxJava2 y Retrofit2 (en Kotlin). Una vez que ejecuto la llamada, la pantalla se vuelve negra y la aplicación ya no responde, sin ningún post de logging. La URL de llamada que estoy usando es la siguiente: api/apartments?projection={"id":1,"address":1} […]

Confundido sobre la asignación de la variable RxJava

Tengo una function que toma una cadena de nombre de usuario y devuelve si el usuario ya existe en una database MongoDB. Soy nuevo en el model RxJava y Retrofit, y estoy confundido acerca de dos para asignar variables una vez que me suscribo al object Observable. fun handleUsername(username: String): Boolean { var userExists = […]

RxJava 1.x .zip () no funciona en RxJava 2.0

Estoy tratando de aprender las requestes de cadena con RxJava + Retrofit + Kotlin. El tutorial que estaba siguiendo era usar RxJava 1.x, así que cuando bash volver a implementarlo con RxJava 2.x, no puedo hacer que funcione .zip () . Es una aplicación simple que utiliza Star Wars API, devuelve una list de películas, […]

Enfrentando problemas con la implementación de Rx Java con la architecture de flujo en Android kotlin

Estoy implementando la architecture de flujo en kotlin y tratando de usar RX java en ella. Hice un despachador que se usa para despachar events y escuchar events. Dispatcher.kt class Dispatcher @Inject constructor() { private val mBus:Subject<Any> init{ mBus = PublishSubject.create() } fun <A : IEvent> dispatchUserEvent(@NonNull e:A) { mBus.onNext(e) } fun <E : IEvent> […]

¿Cómo soluciono el error de inferencia de tipo en un Completable transformado utilizando RxLifecycle.bindToLifecycle ()?

Estoy usando Kotlin y RxJava2. Funciona bien en otros types, es decir, Observable, etc., pero cuando uso un tipo Completable me da un error de inferencia tipo: type inference failed: Not enough information to infer parameter T in fun <T> bindToLifecycle(): LifecycleTransformer<T> Please specify it explicitly Aquí está el código que estoy usando: viewModel .updateText(returnedText) […]

Tipo de devolución diferente en RxJava 2 (actualización desde RxJava1)

Estoy migrando nuestra aplicación de RxJava 1.xx a RxJava 2.xx Tengo un problema con uno de mis methods: devuelve un tipo de devolución diferente. Tenía este método en la versión 1.xx: fun permissionsUsers(groupId: String): Observable<PermissionsUsers?> { return DatabaseRead.permissions(groupId) .flatMap { Observable.from(it).map { combineLatest(DatabaseRead.user(it.getId()), Observable.just(it.level), ::UserLevel) }.toList() } .flatMap { Observable.combineLatest(it) { var owner: User? = […]

RxJava salida diferente entre Flowable y Observable con window y Groupby

Estoy usando RxJava2 con un código que se networkinguce a algo como esto: val whitespaceRegex = Regex("\\s+") val queryRegex = Regex("query=([^&]+)", RegexOption.IGNORE_CASE) val dateTimeFormatter = DateTimeFormatter.ISO_OFFSET_DATE_TIME @JvmStatic fun main(args: Array<String>) { val cnt = AtomicLong() val templateStr = "|date| /ignonetworking/ query=|query|" val random = ThreadLocalRandom.current() var curDate = ZonedDateTime.of(LocalDate.of(2016, Month.JANUARY, 1), LocalTime.MIDNIGHT, ZoneId.of("UTC")) val generator […]

Android Architecture Components Room ViewModel CompleteableFormAction

Así que pensé en probar Room en un pequeño proyecto secundario. Seguí el proyecto de ejemplo de Florina Muntenescu: android-architecture-components Prest particular atención a las classs: UserActivity.kt , UserViewModel.kt , UserDao.kt UserViewModel#updateUserName() devuelve un Completable y tiene que estar suscrito a onComplete o onError Cuando bash poner mi equivalente de viewModel.updateUserName(userName) en una cadena RxBindings […]

Error "No se puede combinar Dex" al usar Room + Kotlin

No soy un usuario nativo de inglés. Disculpe mi error de ortografía y gramática. Intento implementar la interfaz de la database de la sala de architecture de Android con Kotlin. Después de introducir Room en mi proyecto, la aplicación produce un error de compilation. Error:Execution failed for task ':app:transformDexArchiveWithExternalLibsDexMergerForDebug'. > com.android.builder.dexing.DexArchiveMergerException: Unable to merge dex […]

Kotlin: Cómo convertir la testing que usa Thread.sleep a RxJava TestScheduler

Estoy escribiendo una testing instrumental, comtesting si cuando guardo algo en un búfer Rx y después de algún intervalo (10 segundos), este tema inserta valores almacenados en mi database Room. La testing es correcta cuando uso Thread.sleep (syncTimeInterval). Quiero escribir esta misma testing usando TestScheduler. Aquí está con la versión Thread.sleep (que pasa la testing): […]