Ребят, подскажите пожалуйста c Rx'ом, ибо я в нем очень силён

Есть ViewModel в которой идет запрос в репозиторий

Код вьюмодельки
disposable = messagesRepository
           .newMessage(threadId, validateField(content), images)
           .observeOn(Schedulers.io())
           .subscribeOn(AndroidSchedulers.mainThread())
Schedulers.io())
           .subscribeOn(AndroidSchedulers.mainThread())
           .subscribe(......)

И следующий код в репозитории
fun newMessage(параметры): траляля  {
     val imagesNew = compressImages() // и вот данная часть кода выполняется в мейн потоке
return api.newMessage(threadId, contentPart, imagesNew)
           .subscribeOn(ioScheduler)
           .observeOn(mainThreadScheduler)
}

Вопрос, почему данный фрагмент кода выполняется в мейн потоке?

Добавил себе debug версию

debug {
            applicationIdSuffix ".debug"
            debuggable true
        }

и сразу выдало ошибку после Sync'a

ERROR: Library projects cannot set applicationIdSuffix. applicationIdSuffix is set to '.debug' in build type 'debug'.
Affected Modules: smandarine-library

Друзья, а есть какой-то способ сделать так, чтобы Flowable эмитил только новые или обновлённые объекты из БД, а не все, когда в базе что-то обновилось? Пока только придумал на уровне репозитоиия хранить последнюю выдачу из БД, как только БД заэмитит весь список, в .map сравнить последнюю выдачу с новой.

Щас бы через Flowable данные из БД эмитить.

Щас бы через Flowable данные из БД эмитить.

а через что щас эмитят?

Давай на Observable поменяем

.distincstUntilChanged или как там его, не оно? Если equals у моделей правильный, должно сработать

А лучше Single<List<Data>>

Давай на Observable поменяем

А почему AS Canary 3 может не показывать “Build Speed” ?
Там версия плагина какая-то должна быть конкретная или гредла?

Если используется рум, то нельзя так, вроде

почему нельзя? можно, только что это даст? в данном контектсе Flowable от Observable не будет отличаться же

нуу, логично, у библиотек нет applicationId