Использование RxJava 2 и Retrofit 2, проблема версии адаптера

Я добавил новый модуль библиотеки в существующий модуль приложения в Android Studio. Основным отличием было добавление RxJava 2 и Retrofit 2. После обновлени...

@IgorGanapolsky Например, если вы прослушиваете события из другой системы и эта система сообщает о том, что она закончилась, вы можете сообщить, что она уже была удалена, вместо того, чтобы тратить время на отмену регистрации событий.

у создать

Просто используйте

Обработка пустого ответа с помощью дооснащения и rxjava 2.x

 о том, как работает Ленивый.

Это ошибка, она уже исправлена ​​и будет выпущена с

росто, DAO @Query("DELETE FROM Things WHERE someIdOfTheThing IN (:listOfId)") abstract fun deleteThings(listOfId: MutableList<String>): Maybe<Int>использование, mDisposables.add(mThingsDao .deleteThings(listOfId) .subscribeOn(Schedulers.io()) ...

 -> Вы выполняете что-то внутри них. то есть выражение

понимаю реальной разницы между фигурными скобками и обычными скобками в Kotlin при использовании RxJava. Например, у меня есть следующий код, который работает как ...

 вызовет новый буфер с самым первым пустым буфером.

я есть наблюдаемая, которая излучает большое количество данных, таких как [1,1,1,2,2,2,3,3,1,1,5,5 ......] В RxJava мы можем использоватьdistinctUntilChanged () [http://reactivex.io/documentation/operators/distinct.html]чтобы получить отдельные ...

Concat приведет к той же проблеме, что и описанная выше. Это будет решено немедленно. Поэтому, если вы действительно зависите от своего вызова, прежде чем придерживаться doThingA (). AndThen (Completable.defer (() -> doThingB ()).

я есть два дополнения. Я хотел бы сделать следующий сценарий: Если первый Completable попадает в onComplete, продолжить со второго Completable. Окончательные...

 везде.

аюсь использовать rxJava, rxAndroid, Retrofit2 и OkHTTP3 для загрузки файла с конечной точки URL. Мой код не может создать адаптер вызова для «Observable &lt...