Retrofit + RxJava: как запросить несколько запросов по порядку и собрать результаты в одиночном наблюдении?

Question

Я использую RxJava + Retrofit.

Например, есть статья

public class Article { 
    private Long articleId; 
    private Long userId; 
    private String image; 
    private String text; 
    ... 
} 

пользователя и

public class User { 
    private Long userId; 
    private String userName; 
    private String image; 
    ... 
} 

И есть два служб по

• Observable<List<User>> getUserByUserIds(List<Long> userIds) и
• Observable<List<Article>> listArticles(int pageIdx, int pageMax)

Я хочу перечислить 10 статей и связанных с ними авторских данных пользователя, собрать их в нечто вроде Observable<List<Pair<Article, User>>>, возможно ли это?

Answer 1

Одним из способов может быть использование оператора zip, который может объединять несколько Observables вместе. Вы можете прочитать больше here. Просто пройти два наблюдаема почтовый оператор

Answer 2

Это должно сделать трюк:

listArticles(int pageIdx, int pageMax) 
.flatMapIterable(list->list) 
.flatMap(article -> 
    getUserByUserIds(article.userId) 
    .subscribeOn(Schedulers.io()) 
    .flatMapIterable(list->list), 
    Pair::of 
) 
.toList(); 

Однако API плохо specced; Наблюдатели уже имеют врожденный порядок, нет необходимости обертывать все в список. getUserByIds - вернет ли он одного пользователя или нескольких пользователей? Почему бы не использовать один id для метода User? Почему в примитивах объектов домена нет идентификаторов? Ожидаете ли вы иметь предметы без идентификаторов?