Больше ничего не нужно. Ошибку отрабатывай во вьюмодели обычным onError. onError первого источника не дойдет до вьюмодели

Всем привет. Такой вот вопрос. Мне нужно сделать несколько Api запросов с использовнием Retrotit  и RxJava.
В первом запросе я получаю список из 20 фильмов. Мне нужно выводить список фильмов и инфу под каждым фильмом на экран. Чтобы получить инфу об фильме мне нужно сделать второй Api запрос передав туда id фильма и в ответ я получу один объект с инфой о фильме, а мне нужно получить 20 таких объектов с инфой для каждого фильма. Проблема в следующем, как это сделать с RxJava чтоб в репозитории я скомбинировал два запроса и вернул список из 20 фильмов с инфой для каждого фильма?

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

Могу ли я это сделать в репозитории замапить эти данные в обьект с фильмом и инфой о нем и вернуть из репозитория список этих 20 обьектов?

Я ретрофит не юзал для цикличных запросов, всегда Okhttp обходился

Хотя там аналогично

Просто напиши
return Single.create{emitter->
   emitter.onSuccess(готовый лист)
}

А внутри перед onSuccess работай с листами, мапь их и т.д.

как я могу получить лист из 20 обьектов с инфой? Я понимаю что нужно сделать 20 запросов, но как это сделать в RxJava и сохранить эти 20 запросов в лист?

ну получил один, добавил в лист и т.д. Цикл в помощь

Ок, например я создаю Observeble1 для получения 20ти фильмов, дальше что, нужно в этом же Observeble1 делать 20 запросов для инфы с помощью цикла и сохранять ответы в отдельный лист?

Я все понимаю что нужно сделать 20 запросов, сохранить результат в лист а затем взять этот лист и 20 фильмов и мапить это все в один обьект, но я не могу понять саму концепцию как это сделать в RxJava

Как мне собрать результат из 20ти запросов в лист?

возможно подойдет http://reactivex.io/RxJava/3.x/javadoc/io/reactivex/rxjava3/core/Observable.html#zipArray-io.reactivex.rxjava3.functions.Function-boolean-int-io.reactivex.rxjava3.core.ObservableSource...-  не знаю точной задачи

все, понял, можно примерно так:

Observable.fromIterable(films)
     .flatMap(film -> loadFilmFullInfo(film.getId()))
     .map(filmFuilInfo -> \\some mapping to ui model)
     .toList()

Я получаю список фильмов в RxJava  и как я должен возвращать этот список чтоб передать его в метод Observable.fromIterable(films),  Single<List<Fims>>  или по другому??

У меня есть N отдельных retrofit запросов, которые я обрабатываю. Как RxJava отправляет эти запросы? После завершения запроса отправляет следующий или отправляет следующий после полной обработки предыдущего, со всеми операторами? Вроде второй вариант. Если это так, то могу ли я заставить отправлять второй запрос как можно быстрее?