Articles of rx java

OnComplete nunca se llamó con toSortedList () y groupBy ()

Actualmente estoy usando la Biblioteca de ReactiveLocation de Android ( Github ). LastKnownLocationObservable ( Code ) funciona según lo previsto. Estoy usando flatMap para search estaciones cercanas desde un DB y (debido a su dominio) estoy creando un model a partir de los datos. Así que tengo una list de elementos y estoy creando el […]

MissingMethodInvocationException probando una class abierta en Kotlin

Estoy intentando hacer algunas testings de integración con Kotlin + RxJava y MockWebServer. Soy un poco novato en términos de testings y soy aprendiz de Kotlin. Conozco las limitaciones de Mockito y las classs finales, pero no debería burlarme de la class que trato de probar, así que no sé cuál es el verdadero problema: […]

Fusionar datos de diferentes Observables y elegir diferentes estrategias de búsqueda, según la disponibilidad de datos

Tengo una situación en la que, al search un object Item , debe ocurrir una de estas tres cosas: Si el elemento no está presente en la memory caching (también conocido como nulo), cargue datos de api1 y api2 , api2 los datos y devuelva un Observable . Si el elemento está presente en la […]

RxJava – ¿Entradas de keyboard de contrapresión?

Aquí hay un problema divertido de RxJava. Quiero usar los operadores de contrapresión de RxJava para search rápidamente una input mecanografiada mientras se escribe cada carácter, al igual que hace Google en su página de búsqueda. Revisé la documentation de Backpressure y se me ocurrió esto (estoy usando RxJavaFX / RxKotlinFX para aprovechar JavaFX). val […]

Rx Java Retrofit con flatMap se ejecuta solo una vez

Estoy tratando de get un observable de una secuencia de button, click flatmap con otro observable de la modificación para solicitar un punto final, ¡pero solo se ejecutará una vez! Cuando hago clic de nuevo, no paso por el método de map plano. Es extraño porque cuando el map plano devuelve otros observables, funciona bien, […]

Datos de caching de request HTTP en RxJava

Tengo esta FilmStore que busca una película de una API REST. class ApiFilmsStore(private val tmdApi: TmdApi, private val converter: ApiFilmToFilmConverter) : FilmsStore { override fun get(filmId: String): Observable<Film> { return tmdApi.filmById(filmId).flatMap { apiFilm -> Observable.just(converter.convert(apiFilm)) } .subscribeOn(Schedulers.newThread()).observeOn(AndroidSchedulers.mainThread()) } } Tengo este otro que es un decorador para devolver datos de la memory caching si existe: […]

Usando RxJava con Handler, restablece Message.what value

Rxjava 1.1.8 La idea es escuchar los posts del manejador con suscripciones pero el message.what atributo viene con 0 siempre. class RxHandler(looper: Looper) : Handler(looper) { val messagesObservable = PublishSubject<Message>() override fun handleMessage(msg: Message?) { super.handleMessage(msg) msg?.let { messagesObservable.onNext(it) } } } y luego suscribirse a él: playbackHandler.messagesObservable .subscribe({ // it.what is always 0 }, […]

Cambiar Observable desde AutoCompleteTextView a EditText

Estoy tratando de editar algunos códigos preexistentes utilizando Kotlin y RxJava para tener un layout de interfaz de usuario mucho mejor que la forma en que se presenta ahora al usuario. La interfaz de usuario inicial usó AutoCompleteTextEdit para presentar los resultados de Google Places del usuario a medida que el usuario escribe. Estoy tratando […]

¿Por qué obtengo una android.os.TransactionTooLargeException en mi aplicación de Android escrita en Kotlin / rxJava cuando salgo de la aplicación? (onExit / onPause)?

Estoy trabajando en una aplicación en Kotlin / rxJava y he estado luchando con un error desde hace un time. Cada vez que salgo de la aplicación, aparece una window emergente donde dice: "Desafortunadamente, AppName se ha detenido". Aparece este error en la console: java.lang.RuntimeException: android.os.TransactionTooLargeException: tamaño del package de datos 896824 bytes **enter code […]

Cómo combinar el flatmap y el anterior Single

Hay un código de trabajo siguiente, que combina los resultados de .connect() y .auth() . auth() depende del resultado de connect() . En total, es necesario combinar los resultados api y auth en el object Connection . fun getConnection(token: String): Single<Connection> { return connect() .map { Api(it) } .flatMap { api -> api.auth(token) .map { […]