Articles of rx kotlin

Rxjava с kotlin

Я использую rxjava 2 в kotlin, но он не компилируется, как я должен его решить? var emailField = name.textChanges().skipInitialValue().toFlowable(BackpressureStrategy.LATEST) var passField = password.textChanges().skipInitialValue().toFlowable(BackpressureStrategy.LATEST) Flowable.combineLatest(emailField,passField, BiFunction { t1, t2 -> t1.isNotEmpty() && t2.isNotEmpty() })

Получение исключения NetworkOnMainThread с помощью RxKotlin

Я пытаюсь сделать сетевой запрос, используя RxKotlin, но продолжаю получать NetworkOnMainThreadException Я подписываюсь на основной поток, поэтому я не уверен, почему он не снимает его с потока пользовательского интерфейса. Здесь я подписываюсь на Наблюдаемый weatherInteractor.getWeather(lat, lng) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( {response -> try { val jsonData = response.body().string() val currentWeather = getCurrentWeatherData(jsonData) view!!.displayCurrentWeather(currentWeather) } catch (e: […]

Как сделать цикл, как указано ниже, на языке программирования kotlin?

Как я могу сделать это в kotlin, используя для цикла? for (double i = 0; i < 10.0; i += 0.25) { System.out.println("value is:" + i); }

Я не могу получить карту из группы в rxkotlin

не могли бы вы помочь мне в этой группе rxkotlin не работает ? работая в rxjava, но не котлин. высоко оценивайте свою помощь

как реализовать Switch, используя привязку данных в android

это мой 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" android:onCheckedChanged="@={notificationViewmodel.checked}" […]

Как показать диалог «Прогресс» и «Отклонить»

override fun itemclick(position: Int) { binding.progressbar.visibility=View.VISIBLE binding?.barcode?.setImageBitmap(exchngeViewModel.getQrImageBitmap(qrCodeData[position], this!!.activity!!)) showDetail(position) binding.progressbar.visibility=View.GONE } fun getQrImageBitmap(data: String, context: Context): Bitmap? { bitMap = AppUtils.TextToImageEncode(data, context, bus) return this!!.bitMap } Это мой код, который я хочу отобразить в dialog Прогресс dialog на клике по нему, он должен getQrImageBitmap до того времени, когда getQrImageBitmap и функция showDetail завершены, но я […]

OnComplete никогда не вызывал с toSortedList () и groupBy ()

В настоящее время я использую библиотеку Android-ReactiveLocation ( Github ). LastKnownLocationObservable ( Code ) работает по назначению. Я использую flatMap для извлечения соседних станций из db и (из-за сферы) Я создаю модель из данных. Поэтому у меня есть список элементов, и я создаю новый Observable в flatMap с Observable.from(data) . Затем я хочу сортировать местоположения, […]

Невозможно изменить текст ActionMenuItemView с помощью RxKotlin

Я пытаюсь написать приложение для Android с Kotlin. Теперь я хочу показать счетчик в ActionBar. Я добавил для него элемент, названный show_timer. Каждую секунду он должен подсчитывать один: 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) } Но почему-то это не работает. Он […]

RxJava – Входы клавиатуры с обратным давлением?

Вот забавная проблема RxJava. Я хочу использовать операторы RxJava backpressure для быстрого поиска введенного ввода, когда набирается каждый символ, подобно тому, как Google делает на своей странице поиска. Я просмотрел документацию Backpressure, и я придумал это (я использую RxJavaFX / RxKotlinFX для использования JavaFX). val myControl: Node = … val burstyMulticast = myControl.events(KeyEvent.KEY_TYPED).publish().refCount() val burstyDebounced […]

Как уведомить Observable при завершении CountdownTimer

У меня есть пользовательский Android TextView, который показывает количество времени, оставшегося в игре, через 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) { override fun onTick(millisUntilFinished: Long) { val […]