Конкатентные множественные вызовы с дооснащением 2 и rxJava

Question

Мне нужно конкатенировать несколько вызовов API, и я хотел бы использовать для этого функции retrofit2 и rxJava. Мой сценарий выглядит следующим образом:

я должен сделать первый звонок, который будет возвращать массив объектов, то ответ будет что-то вроде:

[{"title": "Title 1", "id": "1"}, {"title": "Title 2", "id": "2"}] 

Тогда мне нужно сделать вызов API по каждому объекту, поэтому ответ API для каждого объекта будет что-то вроде:

[{"title": "Chapter A", "id": "1A", ...}, {"title": "Chapter B", "id": "1B", ...}, ...] 

так что я хочу Concat всех этих вызовов и объединить его в уникальном объекте ответа, который будет иметь всю информацию. Как я мог это сделать? Как я могу выполнить первый вызов, а затем ответить на вызов на объект и дождаться завершения всех вызовов и слияния результатов?

Большое спасибо

Answer 1

Предположим, у вас есть объекты с заданными свойствами:

public class TvShow { 
    public String title; 
    public Long id; 
    public List<TvChapter> chapterList; 
} 

public class TvChapter { 
    public String title; 
    public String id; 
} 

И у вас уже есть методы, чтобы получить данные:

public Observable<List<TvShow>> getShows() 

public Observable<List<TvChapter>> getTvChapters(Long tvShowId) 

Вот объединенный RxJava поток, который возвращается Observable<List<TvShow>>:

getShows() 
     .flatMap(new Func1<List<TvShow>, Observable<TvShow>>() { 
      @Override 
      public Observable<TvShow> call(List<TvShow> tvShows) { 
       return Observable.from(tvShows); 
      } 
     }).flatMap(new Func1<TvShow, Observable<TvShow>>() { 
    @Override 
    public Observable<TvShow> call(TvShow tvShow) { 
     return Observable.zip(Observable.just(tvShow), 
       getTvChapters(tvShow.id), 
       new Func2<TvShow, List<TvChapter>, TvShow>() { 
        @Override 
        public TvShow call(TvShow tvShow, List<TvChapter> tvChapters) { 
         tvShow.chapterList = tvChapters; 
         return tvShow; 
        } 
       }); 
    } 
}).toList(); 

Идея заключается в следующем:

1. Fetch всех шоу (getShows)
2. Получить поток отдельных шоу из списка (Observable.from() оператора)
3. Получить глава для каждого шоу (getTvChapters(tvShow.id))
4. комбината Результаты tvChapters позвонить по телефону tvShow
5. Слияние всех результатов (Observable.toList())

Answer 2

с использованием лямбды

getTitlesList() //first API call that returns Observable<Titles> 
     .flatmap(titles -> Observable.from(titles)) //forcing list to emit each element separately 
     .flatmap(title -> getDetail(title)) //second API call that returns Observable<Detail> 
     .toList() //collect all emitted items to list 
     .subscribeOn(Schedulers.io()) // don't forget to apply async scheduler, 
            // otherwise you'll get *android.os.NetworkOnMainThreadException* 
     .observeOn(AndroidSchedulers.mainThread()) //and switch thread back to main, if needed 
     .subscribe(details -> { 
      //process your details list 
     }, e -> { 
      //error handling 
     });