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

Question

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

силён

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

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

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

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