Articles of rx java

Что такое idomatic способ обновления с использованием RxBinding на SwipeRefreshLayout

Я изо всех сил пытаюсь понять, как правильно использовать RxBinding , если я хочу вызвать сетевой запрос, когда пользователь SwipeRefreshLayout , я бы хотел сказать что-то вроде RxSwipeRefreshLayout.refreshes(swipeContainer) .flatMap { networkRequest() } .subscribeBy( onNext = { list: List<Data> -> Timber.d(data) }, onError = { showErrorSnackbar(it) }, onComplete = { Timber.d("On Complete") }) Но для меня […]

Получение исключения 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: […]

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

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

Повторная установка + повтор RxJava с другой ссылкой

Я использую Api, который требует запросов: Название фильма Год выпуска фильма Но мой другой Api дает мне только год выпуска для конкретной страны, поэтому мне, возможно, придется повторить запрос с + / – один год. Другими словами, если первый attemp Fails, я хочу повторить попытку с другой ссылкой / запросами. Как я могу достичь этого […]

Как собрать асинхронный ответ с помощью RxJava

Вот моя цель: собрать ответы от асинхронных задач, которые поступают из сторонней библиотеки Требование: используйте RxJava2 для выполнения в порядке Я застрял в мысли, что я использую оператора или операторов для этого, идеи приветствуются. Моя мысль такова: Flowable.fromIterable(list) .anOperatorCanOnNextTheResponse() .buffer() .subscribe(newList)

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

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) . Затем я хочу сортировать местоположения, […]

Использование RxJava с сбросом Handler Message.what value

Rxjava 1.1.8 Идея состоит в том, чтобы прослушивать сообщения обработчика с подписками, но message.what атрибут всегда приходит с 0. class RxHandler(looper: Looper) : Handler(looper) { val messagesObservable = PublishSubject<Message>() override fun handleMessage(msg: Message?) { super.handleMessage(msg) msg?.let { messagesObservable.onNext(it) } } } и затем подписаться на него: playbackHandler.messagesObservable .subscribe({ // it.what is always 0 }, { […]

Выполнение Observable.fromCallable () с исключением

Я пытаюсь выполнить функцию, которая генерирует исключения. Observable.fromCallable { foo() } .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .take(1) .onErrorReturn { /* onError operation */ } .subscribe { } и я хочу сделать некоторые другие операции, если это удастся без каких-либо ошибок. Как я могу это сделать?

Почему я получаю android.os.TransactionTooLargeException в своем приложении для Android, написанном в Kotlin / rxJava, когда я выхожу из приложения? (OnExit / OnPause)?

Я работаю над App в Kotlin / rxJava, и я некоторое время боюсь с ошибкой. Каждый раз, когда я выхожу из приложения, я получаю всплывающее окно, где говорится: «К сожалению, AppName остановился». Я получаю эту ошибку в консоли: java.lang.RuntimeException: android.os.TransactionTooLargeException: размер пакета данных 896824 байта **enter code here** Когда я пользуюсь телефоном с API 23 […]