Наблюдаемый и вложенный список в объекте

Question

Я делаю свои первые шаги с RxJava und Retrofit.У меня есть API отдыха, который возвращает Observable<Department>.Класс Department имеет вложенный список Team объектов.Как я могу получить Observable<Team>, который доставляет все команды из вложенного списка из Observable<Department>?

Я пытался поиграть с map() и switchMap(), но все еще не могу получить желаемый Observable<Team>.

Моя идея состоит в том, чтобы подписаться на Observable<Team>, и для каждой доставленной команды я запускаю некоторую логику обновления.

Answer 1

Вы можете просто создать конвейер, используя карту, чтобы получить внутренние значения, а затем flatMapIterable, чтобы развернуть массивы.

Предположим, dept$ это ваш Observable<Department>

dept$
  .map(d -> d.getTeam())
  .flatMapIterable(teamArr -> teamArr)
  .doOnNext(System.out::println)
  .subscribe();