Articles of rx kotlin

cómo implementar Switch usando Data binding en android

este es mi xml: <data> <variable name="notificationViewmodel" type="com.kdcos.contsync.viewmodel.notification.NotificationViewModel"></variable> </data> <RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android" android:layout_width="match_parent" android:layout_height="match_parent" android:background="@color/colorpalegrey"> <RelativeLayout android:id="@+id/header" android:layout_width="match_parent" android:layout_height="wrap_content" android:layout_alignParentTop="true" android:layout_gravity="center" android:background="#689F38" android:gravity="center"> <include android:id="@+id/layout_toolbar" layout="@layout/toolbar_white_bg" /> </RelativeLayout> <LinearLayout android:layout_width="match_parent" android:layout_height="wrap_content" android:layout_below="@+id/header" android:layout_marginTop="20dp" android:background="@drawable/topbottomborder" android:orientation="vertical"> <RelativeLayout android:layout_width="fill_parent" android:layout_height="wrap_content" android:layout_marginTop="18dp" android:paddingBottom="20dp" android:paddingLeft="@dimen/margin_20dp"> <TextView android:layout_width="match_parent" android:layout_height="wrap_content" android:fontFamily="sans-serif-medium" android:lineSpacingExtra="30sp" android:text="@={notificationViewmodel.getText()}" android:textColor="@color/colorDusk" android:textSize="16sp" android:textStyle="normal" /> <Switch android:layout_width="wrap_content" android:layout_height="wrap_content" android:layout_alignParentRight="true" android:paddingRight="10dp" […]

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 […]

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 […]

No se puede cambiar el text de ActionMenuItemView con RxKotlin

Estoy tratando de escribir una aplicación para Android con Kotlin. Ahora, quiero mostrar un contador en ActionBar. Agregué un artículo llamado show_timer para eso. Cada segundo, debe contar en uno: override fun onWindowFocusChanged(hasFocus: Boolean) { val item = findViewById(R.id.show_timer) as ActionMenuItemView PublishSubject.interval(1, java.util.concurrent.TimeUnit.SECONDS, Schedulers.newThread()) .subscribeBy(onNext = {item.text = it.toString()}) super.onWindowFocusChanged(hasFocus) } Pero de alguna manera […]

Cómo notificar a Observable cuando finalice CountdownTimer

Tengo un Android TextView personalizado que muestra la cantidad de time que queda en un juego a través de un CountDownTimer class CountdownTextView(context: Context, attrs: AttributeSet) : TextView(context, attrs) { private lateinit var countDownTimer: CountDownTimer private lateinit var onFinishObservable: Observable<Unit> fun setTime(initTime: Int) { this.text = "$initTime:00" countDownTimer = object : CountDownTimer((initTime *1000).toLong(), 1000) { […]

RxKotlin – matriz de observadores dynamics

Estoy usando RxKotlin junto con Retrofit 2 Estoy intentando descubrir cómo tener una list dinámica de observadores en una sola operación. El primer observador debe activar la operación, y todos los observadores adicionales deben esperar hasta que la operación se complete / falla Una vez que la operación se completa, necesito realizar la manipulación de […]

¿Cómo especificar la versión de RxJava al usar RxKotlin?

Los documentos en el repository de RxKotlin en GitHub no especifican una forma de depender explícitamente de la última versión de RxJava. Si vemos el file build.gradle de la biblioteca, a partir de ahora utiliza compile 'io.reactivex.rxjava2:rxjava:2.1.0' Pero, ¿qué sucede si queremos estar al día con las últimas versiones de RxJava y no con las […]

Agregar subscribeOn () está cambiando el tipo de retorno de observable

Me he encontrado con un problema extraño que estoy luchando por comprender. He escrito un código que crea un observable de invocable. Se comstack bien, pero tan pronto como especifico un planificador para él, cambia el tipo de devolución y no se comstack. Aquí está el código sin el subscribeOn (que comstack): /** * Gets […]

Inyectar constructor y object complementario

Soy algo nuevo para Kotlin y estoy intentando inyectar un valor (en este ejemplo, es solo un int pero en el código real es una class de proveedor) ¿Qué estoy haciendo mal aquí? y ¿por qué x es una reference no resuelta? class Test @Inject constructor(private val x: Int) { companion object { var y: […]

RxAndroid, cómo detectar si observable ha finalizado la emisión

Estoy escribiendo el siguiente fragment de código para recuperar la list de alimentos guardados de la database de firebase y luego, al usar esa list, vuelvo a search detalles de alimentos individuales de la database de firebase. El siguiente código funciona bien, excepto que no puedo averiguar cómo hacer que el segundo flatMap sepa que […]