Описание тега rx-kotlin

Описание тега Вопросы с тегом
Привязки RxJava для языка программирования Kotlin
5 ответов

Kotlin объединить два обнуляемых изменяемых списка

val mutableList1: MutableList<TeamInvitationData?>? val mutableList2: MutableList<TeamInvitationData?>? МетодaddAll можно использовать для слияния непостоянного изменяемого списка, но здесь он выдает ошибку времени компиляции. Пример: va…
12 янв '18 в 11:22
1 ответ

Как можно условно добавить асинхронную операцию в середине потока RxJava?

Вот упрощенная версия того, что я пытаюсь сделать (используя Kotlin и RxJava) makeServerCall() .doOnNext { doStuff(it) } //TODO: if it == 0, call asyncOperation() and wait for its callback to fire //before running the rest of the stream. Otherwise i…
14 сен '17 в 16:27
1 ответ

Лучший способ кэширования данных в Android с помощью ViewModel и RxJava2

В моем приложении я использую RxJava2 и новый класс от компонентов архитектуры ViewModel. В моем случае мне нужно перенести SQL-предложение в ViewModel, что сделает магию и вернет Observable, который даст мне данные, которые мне нужны. Все работает …
24 фев '18 в 20:17
3 ответа

Как разорвать цепочку RxJava при ошибке Result?

Я унаследовал эту кодовую базу, которая использует RxJava2 и kotlin с довольно своеобразным шаблоном Result для вызовов API. т.е. все вызовы API возвращают Singles с объектом Result (который является запечатанным классом типов Success и Error, как п…
26 янв '19 в 14:04
1 ответ

rx kotlin подписка не работает, не получает предметы

Я создал функцию, которая возвращает Observable<String> с именами файлов, но я не получаю никакого события в моей подписке, где я вызываю этот метод. Также нет вызова onError или onComplete Смотрите мой код: fun getAllFiles(): Observable<St…
05 мар '16 в 19:00
1 ответ

Упростите утверждение, используя rxkotlin

Я хотел попробовать RxJava с kotlin, чтобы упростить кодирование, поэтому я произвел это: fun postAnswers() { disposable = getToken.execute().subscribe({ token -> questions.forEach { form -> val answers = form.answers?.filter { it.isChecked }?…
06 янв '19 в 11:01
1 ответ

Как молча пропустить исключения в RxJava2?

У меня есть поток данных, как это: Observable .fromFuture( CompletableFuture.supplyAsync { // First remote call returns Future<List<Type>> listOf(1, 2, 3, 57005, 5) }, Schedulers.computation() ) .flatMap { it.toObservable() } // I turn t…
24 авг '17 в 23:43
1 ответ

Использование RxJava для объединения локальных данных с удаленными (или кэшированными) данными

Это рабочий код, но у меня есть несколько вопросов, а также просьба о совете по его улучшению. Я новичок в RxJava, и я не полностью обдумал, как связать эти типы наблюдаемых вместе. У меня есть два модельных объекта, ListItem а также UserInfo, ListI…
20 фев '16 в 15:04
1 ответ

ReactiveX - от одного<T> до одного<R>

Я пытаюсь сделать пример проекта с подходом чистой архитектуры, и у меня есть некоторые трудности для преобразования одного в другой. У меня есть сервис по модернизации (сингл): @GET("nearbysearch/json") fun getNearbyPlaces(@Query("type") type: Stri…
10 сен '18 в 10:39
1 ответ

Kotlin, как можно повторить запрос при получении ошибки при нажатии на кнопку диалога

Давайте представим ситуацию на Kotlin, когда мы пытаемся получить запрос, но не имеем подключения к Интернету, и мы получаем ошибку, затем показать AlertDialog, и нам нужно повторить запрос, если пользователь нажмет "положительную кнопку". Этот мето…
28 мар '18 в 18:05
0 ответов

RecyclerView не прокручивается и щелчок элемента не работает в окне навигации.

&lt;android.support.v4.widget.DrawerLayout xmlns:android="http://schemas.android.com/apk/res/android" xmlns:app="http://schemas.android.com/apk/res-auto" xmlns:tools="http://schemas.android.com/tools" android:id="@+id/drawer_layout" android:divider=…
11 янв '18 в 04:44
0 ответов

LocationAwareException: не удалось выполнить задачу ':app:kaptGenerateStubsDebugKotlin'

У меня есть проблема на kotlin отладке, не нашел проблему. Всегда отображается "Выполнение не выполнено для задачи": app: kaptGenerateStubsDebugKotlin '. не знаю, что не так, я думаю, что это ошибка версии, которую я использую для kotlin. Я использу…
12 дек '18 в 06:38
2 ответа

RxJava/RxKotlin жалуется на доступ к представлениям

У меня есть следующий вызов для получения некоторых данных с сервера и обновления пользовательского интерфейса в соответствии с ответом. poiAPIService.getPoiDetails(poiId!!) .observeOn(AndroidSchedulers.mainThread()) .doOnSubscribe { showProgressBar…
17 дек '18 в 09:22
1 ответ

onNext() никогда не вызывается для PublishSubject

Я пытаюсь построить презентатор, который вычисляет некоторые события за определенный период времени, показывает загрузку только при первой загрузке и обновляет пользовательский интерфейс, когда это будет сделано. Поскольку события могут обновляться …
05 авг '17 в 02:09
1 ответ

Создайте отфильтрованную наблюдаемую из 2 наблюдаемых списка элементов в RxJava

Я работаю над функцией, где мне нужно отфильтровать данные ответа сети на основе данных локальной базы данных. Например, мои сетевые уровни возвращают мне список элементов, а мой уровень базы данных возвращает наблюдаемый список идентификаторов. Теп…
18 ноя '18 в 12:35
1 ответ

Ошибка: ни одна из следующих функций не может быть вызвана с аргументами, предоставленными при преобразовании в Kotlin из Java

Я видел другие вопросы здесь, связанные с этой ошибкой, но все еще не удалось исправить. Кроме того, я задаю этот вопрос, потому что в отличие от других вопросов здесь, я получаю эту ошибку, только когда я конвертирую код в Kotlin из Java. Я использ…
31 май '18 в 13:10
1 ответ

RxKotlin - Single.just() не выдается при подписке TestSubscriber

Я думал, что это так, кажется, я что-то упустил.. @Test fun singleCompletes() { val testSubscriber = TestSubscriber&lt;Boolean&gt;() Single.just(true) .subscribeOn(Schedulers.immediate()) .subscribe { testSubscriber } testSubscriber.assertNoErrors()…
01 фев '17 в 19:08
3 ответа

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

Как я могу сделать это в Kotlin, используя для цикла? for (double i = 0; i &lt; 10.0; i += 0.25) { System.out.println("value is:" + i); }
21 июл '17 в 09:32
1 ответ

RxKotlin collectInto() MutableList с использованием ссылок на методы

Следующий код - моя попытка преобразовать пример RxJava в Kotlin. Это должно собрать кучу Intв MutableList, но я получаю массу ошибок. val all: Single&lt;MutableList&lt;Int&gt;&gt; = Observable .range(10, 20) .collectInto(::MutableList, MutableList:…
15 июн '17 в 22:54
1 ответ

Могу ли я создать метод расширения Kotlin для добавления подписки rxJava в подписку CompositeSubscription?

Я играл с Kotlin/RxJava и пытался создать метод расширения для добавления Subscription к CompositeSubscription, это будет работать так: search.subscribe { //do stuff }.addToComposite(compositeSubscription) Это моя попытка до сих пор: fun Subscriptio…
14 мар '16 в 18:48