И всё равно мне не даёт покоя вопрос, как нормально "протаскивать" какой-то объект / пачку объектов через пайплайн. Пробовал создавать object и везде возвращать его, создавая новый - но что-то дюже вербозно и уродливо. Не говоря уже о том, что компилятор иногда ёбается и в рантайме ClassNotFoundException кидает. А постоянные зипы эти тоже какая-то шляпа. Может, я пытаюсь заставить rx сделать то, для чего он не предназначен, но так хочется верить в чудо...

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

Всем привет! У меня есть класс со списком объектов внутри. Я хочу изменить значения этих объектов
значениями(observable), которые получаю с репозитория и вернуть главный объект,
завернутый в observable. Как мне этого достич? Вот код.

data class MainModel(secondModels: List<SecondModel>)

data class SecondModel(var value1: String, var value2: String)

//хочу что-то наподобие, но не знаю, как вернуть Observable<MainModel>
val mainObject: Observable<MainModel> = Observable.just(mainModel)
 .map { it.secondModels }
 .flatMap {
   val data = repository.getData()
   it.value1 = data.value1
   it.value2 = data.value2
 }

Observable.just(mainModel)
   .flatMap {  main ->
       repository.getData().map {
           // do something with data and assign data to main
          // return main
       }
   }

Нет, немного не так, у меня для каждой secondModel своя data с репозитория, исправил в вопросе, изначально не заметил, сори

Дословно писать не буду, главное суть улови и переделай. Но как то так должно работать

Single.just(main)
 .flatMap { main ->
   Observarvable.fromIterable(main.second)
     .concatMapSingle { second ->
       repository.getData(second)
         .map{ data ->
           // do something with data and second and return
         }  
     }
     .toList()
     .map { main.second = it }
 }

спасибо

Вообще мутабельность это не очень хорошо (зависит конечно, но обычно лучше вернуть новый объект), как и пользоваться observable везде, где подойдут другие вещи, вроде Single. Не первая rx Java поди

про мутабельность знаю, у меня ее нет, тут добавил для простоты) rxjava 2

Подскажите пожалуйста оператор: мне нужно если Single приходит null, то сразу завершать с ошибкой

сингл не может эммитать null

и выплюнет ошибку сам

спасибо!

вообще никто в RxJava2 не может)

что ему не нравится?

или я ёбнулся, или котлин(

onErrorResumeNext { t: Throwable -> Observable.just(item) }

да, я уже так написал, но мне интересно, почему оно всё почёркало?

типа я же синтаксически правильно написал...

неправильно, там сначала идет сигнатура лямбды, а потом что-то еще