У меня есть 2 вызова:
getItems()
- возвращаетList<Item>
, такжеItem
имеет полеid
getParam(id)
- возвращаетParam
Мне нужно сделать getItems()
, а затем getParam(id)
для каждого Item
в List
, а затем нужно обновить каждый Item
с полученным Param
Мой вопрос:
Как я могу сделать это с помощью RxJava?
api.getItems()
.flatMapIterable(new Func1<List<Item>, Iterable<Item>>() {
@Override
public Iterable<Item> call(List<Item> items) {
return items;
}
})
.flatMap(new Func1<Item, Observable<?>>() {
@Override
public Observable<?> call(Item item) {
return api.getParam(item.id)
}
}),
...
.subscribe(...);
Заранее спасибо.