RxJava：如何将单个<Response>转换为单个<列表<Item>>

Question

假设我有一个Android应用程序，它具有以下Repository类，可以从API获取对象：

override fun fetchOrderById(orderId: Long): Single<List<ItemRow>> {
return api.fetchOrderByIdObservable(orderId)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.map { orderResponse ->
orderResponse.items.map { deliveryItem ->
deliveryItem.asItemRow()
}
}
}
override fun fetchOrders(): Single<OrdersResponse> {
return api.fetchOrdersObservable()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
}
override fun fetchAllOrders(): Single<List<ItemRow>> {
// TODO
}

具有以下数据类别：

class OrdersResponse(@SerializedName("orders") val orders: List<Long>)
class OrderResponse(@SerializedName("items") val items: List<DeliveryItem>)

现在，我可以使用fetchOrderById获取某个orderId的所有交付项目(ItemRow(，作为应用程序中的域对象显示在列表中。如何使用fetchOrders，它返回orderId列表以获取所有订单的所有交货项目？哪些运算符在这里有用？我玩过FlatMap，但没能让它发挥作用。文章链接也是++。谢谢

Answer 1

您需要的运算符：switchMap()、flatMap()、fromArray()、toList()、map()

fun fetchAllOrders(): Observable<List<ItemRow>> {
return fetchOrders()
.toObservable()
.switchMap { ordersResponse ->
Observable.fromIterable(ordersResponse.orders)
.flatMap {orderId -> fetchOrderById(orderId).toObservable() }
.toList()
.toObservable()
}
.map { list -> list.flatten() }
}

Answer 2

这最终奏效了：

public fun fetchAllItems(): Observable<List<ItemRow>> {
return networkService.api.fetchOrdersObservable()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.flatMap { orderResponse ->  Observable.just(orderResponse.orders) }
.flatMapIterable { id -> id }
.flatMap { id -> fetchOrderById(id) }
.flatMapIterable { itemRow -> itemRow }
.toList()
}