нет, я не первый раз поподаю в чат с такой кнопкой, но сейчас её нигде небыло, я даже больше скажу, я её так и не нажал)

Всем привет! Кто может помочь разобраться в javaRX? Хочу по очереди 2 метода вызвать

concat* используй

эм, в каком там месте?)

120 и 122 строка, если что*

А вы подумайте вам действительно нужно использовать rxjava для последовательного вызова двух методов ?

Я уже отказался от этой затеи)) мне выше много кто смог переубедить)

М, не в этой беседе*

ну и отлично. Плохо когда рх тянется туда где оно не нужно ж)

))

Можно ли с помощью rx получить список категорий с сервера, запросить для каждой категории айтемы, заполнить категории и отдать заполненными? У меня получилось так https://pastebin.com/raw/PMeWa1ij Но так я теряю попути  принадлежность айтемов к категории

Тут видимо doOnNext надо использовать

попробуй как-то так

mRepository.getCategories()
        .flatMap(Flowable::fromIterable)
        .flatMap(category -> mRepository.getItemsInCategory(category.getContentCategoryID())
                        .doOnNext{ it.forEach { it.setCategory(category)}})
        .subscribe(items -> mExploreScreenView.showBanners(items));

не факт, что скомпилиться - но идею, я думаю, ты понял

Попробую, спасибо

Бож, откуда вы беретесь?

Ребят, подскажите пожалуйста, в 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)
}

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

.observeOn(AndroidSchedulers.mainThread())
           .subscribeOn(Schedulers.io())

val imagesNew = compressImages()

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

disposable = messagesRepository....

поэтому он и выполняется синхронно с потока, на котором был вызван

val imagesNew = compressImages()

disposable = messagesRepository....

Спасибо
Можно еще совет, как правильно вернуть данные из compressImage() асинхронно, чтобы передать дальше параметров в запрос к апишке?