java - RxJava迭代对象中的列表并返回对象

Question

需要执行 API 请求并下载响应中返回的所有资源。 我有下面的逻辑，但不确定完成此操作的正确方法是什么。

 public Observable<Response> prepareSomething() {
    return api.requestSomthing()
            .observeOn(Schedulers.io())
            .flatMap(response -> Observable.fromIterable(response.getAssetsList()))
            .map(asset -> downloadAsset(asset, response.getSomeValue/*how?*/))
            .someRxOperatorToRetrunResponseObject(/*how?*/);
}

我实际上找到了一种通过以下方式实现它的方法:

public Observable<Response> prepareSomething() {
    return api.requestSomthing()
            .observeOn(Schedulers.io())
            .flatMap(response -> {
                ArrayList<Observable<Asset>> observables = new ArrayList<>();
                for(Asset asset : response.getAssetsList()){
                    Observable downloadOb = Observable.just(asset)
                            .map(assetToDownload-> downloadAsset(assetToDownload, response.getSomeValue()));
                    observables.add(downloadOb);
                }

                return Observable.zip(observables, objects -> response);
            });
}

但它看起来不太好。如果有人可以帮助改进这一点，我们将不胜感激。

Answer 1

我会将下载逻辑嵌套到内部 Observable 中

public Observable<Response> prepareSomething() {
        return api.requestSomthing()
                .observeOn(Schedulers.io())
                .flatMap(response -> Observable.fromIterable(response.getAssetsList())
                        .flatMap( asset -> downloadAsset(asset))
                        .toList()
                        .flatMapObservable(downloadedAssets -> Observable.just(response))
                );
    }

您可以访问同一 lambda 中的响应和下载的资源