响应中每个项目的RxJava/改装调用

Question

我用改型/rxJava调用我的API，得到了一个可观察的响应，就像一个BreedDog列表

...你可以看到我的代码：

compositeDisposable.add(breedDogsDisplayDataRepository.getBreedDogs(name)
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeWith(new DisposableSingleObserver<List<BreedDog>>() {

                @Override
                public void onSuccess(List<BreedDog> breedDogList) {
                    Log.e("test", "okPresenter");
                    view.displayBreedDogs(breedDogToViewModelMapper.map(breedDogList));
                }

                @Override
                public void onError(Throwable e) {
                    Log.e("test", "errorPresenter : " + e.toString());
                    // handle the error case
                    System.out.println(e.toString());
                }
            }));

这是可行的，但是现在，对于列表中的每一项，我都需要调用API来获取URL图像并更新列表。。但我不知道怎么。。。我试着在Observable中更改我的单个响应，并使用了flatMap或flatMapIterate之类的运算符。。等等，但每次我都会在对象上出错。。没有一个例子。。。等

这是一个例子：

breedDogsDisplayDataRepository.getBreedDogs(name)
            .flatMapIterable(breedDogs -> breedDogs)
            .map( item ->   breedDogsDisplayDataRepository.getImageBreedDog(item.getId())
                    .subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribeWith(new DisposableSingleObserver<List<BreedImageResponse>>() {

                        @Override
                        public void onSuccess(List<BreedImageResponse> breedImageResponses) {

                        }

                        @Override
                        public void onError(Throwable e) {
                            Log.e("test", "errorPresenter : " + e.toString());
                            // handle the error case
                            System.out.println(e.toString());
                        }
                    })));

我用的是好方法吗？或者需要改变什么？

Answer 1

这是我解决问题的解决方案：

public Single<List<BreedDogWithImage>> searchDogs(String name) {
    return getBreedDogs(name)
            .flatMapIterable(breedDogs -> breedDogs)
            .flatMap(breedDog -> getImageBreedDogs(breedDog.getId())
                    .flatMapIterable(breedDogWithImages -> breedDogWithImages))
            .toList();
}

所以我可以这样称呼它：

public void searchBreedDogs(String name) {
    compositeDisposable.clear();
    compositeDisposable.add(breedDogsDisplayDataRepository.searchDogs(name)
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeWith(new DisposableSingleObserver<List<BreedDogWithImage>>() {

                @Override
                public void onSuccess(List<BreedDogWithImage> breedDogWithImages) {
                    Log.e("test", "okCall" + breedDogWithImages);
                    view.displayBreedDogs(breedDogToViewModelMapper.map(breedDogWithImages));
                }

                @Override
                public void onError(Throwable e) {
                    Log.e("test", "error ");
                    e.printStackTrace();
                }
            }));
}

Answer 2

如果没有存储库的签名，很难说到底出了什么问题，但是您确实提到了getBreedDogs返回一个单字符

它将映射单中的列表，并将其项作为可观察项发出。这意味着您不能再使用map，必须切换到flatMap：

.flattenAsObservable(breedDogs -> breedDogs) 
.flatMapSingle(item -> breedDogsDisplayDataRepository.getImageBreedDog(item.getId()))

使用的是平面映射，因为在这种情况下，我们是平面映射Singles

我注意到的另一件事是，您的“订阅部分”位于映射中，您希望从中删除它。因此，理想情况下，你会搬到外面，比如：

.flattenAsObservable(breedDogs -> breedDogs) 
.flatMapSingle(item -> breedDogsDisplayDataRepository.getImageBreedDog(item.getId()))
.subscribeWith(/*...*/);

调度程序由你决定。如果您希望您的图像被并行下载，我建议将它们保存在flatMapSing中。

最后一件事，您似乎希望收到一个列表

breedDogsDisplayDataRepository.getBreedDogs(name)
  .flattenAsObservable(breedDogs -> breedDogs) 
  .flatMapSingle(item ->
    breedDogsDisplayDataRepository.getImageBreedDog(item.getId())
      .subscribeOn(Schedulers.io())
  )
  .toList()
  .observeOn(AndroidSchedulers.mainThread())
  .subscribeWith(new DisposableSingleObserver<List<BreedImageResponse>>() {
        @Override
        public void onSuccess(List<BreedImageResponse> breedImageResponses) { 
        }

        @Override
        public void onError(Throwable e) {}
  });