RxJava api调用扩展项列表和返回列表中的每个项

Question

我使用改型2，我正在学习RxJava。我从某处下载了一个项目列表。我想对每个项目进行api调用，并创建扩展项目的新列表。两个调用都返回一个可观察的。它看起来像这样：

getItemsService.getItems()
            .concatMap(Observable::from)
            .map(item -> new ExtendedItem(item, someOtherService.getDetails(item.somedetail)))
            .toList()
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(activity);

详细服务：

public interface IGetDetailsService {
@GET(BuildConfig.GET_DETAILS_ENDPOINT)
Observable<Detail> getDetails(@Query("q") String someDetail);

}

问题是get细节返回一个可观察的，我不能用它来构造扩展项。在rxJava链中，更改get细节调用以返回对象不起作用，我猜是因为它将结果返回给主线程。如何获取对象本身？我尝试了很多其他的方法，但到目前为止都没有成功。

Answer 1

您可以使用flatMap的一种变体：

...
            .concatMap(Observable::from)
            .flatMap(item -> someOtherService.getDetails(item.somedetail), (item, detail) -> new ExtendedItem(item, detail))
            .toList()
...