使用 Retrofit2 迭代网络 API 调用

Question

所以我正在使用自定义 google 搜索 API 为我的数据集中的每个名称参数获取图像 URL。

我想在对 Retrofit2 的 API 调用中将数据集中的每个名称作为查询参数进行迭代。

public interface GoogleImageAPI {
    @GET("v1?key=MyAPIKEY&cx=MyCustomSearchID&searchType=image&fileType=jpg&imgSize=large&alt=json")
    Observable<Photos> loadPhotos(@Query("q") String artistQuery);
}

到目前为止，我已经将 Retrofit 适配器和 API 实例构建到 return 一个 Observable：

public Observable<Photos> getPhotosObservable(String artistName){
    Retrofit retrofit = new Retrofit.Builder()
            .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
            .addConverterFactory(GsonConverterFactory.create())
            .baseUrl("https://www.googleapis.com/customsearch/")
            .build();
    GoogleImageAPI googleImageAPI = retrofit.create(GoogleImageAPI.class);
    return googleImageAPI.loadPhotos(artistName.replace(" ","+"));
}

我有一个 getPhotos(String name) 方法可以创建一个可观察对象并订阅它。我能够运行这个方法带有一个测试参数 i.e.getPhotos("rocket") 并且它 return 是一个包含前 10 个列表的照片对象 google "rocket"

的照片搜索结果

public void getPhotos(String artistName){
    Observable<Photos> photosObservable = mDataManager.getPhotosObservable(artistName);
    Subscription subscription = photosObservable.subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Subscriber<Photos>() {
            @Override
            public void onCompleted() {

            }

            @Override
            public void onError(Throwable e) {
                if(e instanceof HttpException){
                    HttpException response = (HttpException)e;
                    Log.i(TAG,"bad response: "+response.code());
                }
            }

            @Override
            public void onNext(Photos photos) {
                Photos mPhotos = photos;
                Log.i(TAG,"size: "+mPhotos);
            }
        });
}

是否有 safe/correct 迭代此方法的方法，从而调用 API 100 次而不运行内存不足或创建 100 次可观察对象？

例如，我可以做这样的事情吗？看起来非常耗费资源：

for(String name : artistNames){
    googleImageAPI.loadPhotos(name.replace(" ","+"))
        .subscribeOn(Schedulers.newThread())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Subscriber<Github>() {
        @Override
        public final void onCompleted() {
            // do nothing
        }

        @Override
        public final void onError(Throwable e) {
            Log.e("GithubDemo", e.getMessage());
        }

        @Override
        public final void onNext(Github response) {
            mCardAdapter.addData(response);
        }
    });
}

编辑（工作示例）生成照片对象的组合列表：

public void getPhotos(){
    mDataManager.getArtists()
        .subscribeOn(Schedulers.io())
        .subscribe(new Action1<JSONArray>() {
            @Override
            public void call(JSONArray jsonArray) {
                LinkedHashMap<Integer,Artist> artistMap = presentArtists(jsonArray);
                Collection<Artist> artists = artistMap.values();
                Observable.from(artists)
                   .map(new Func1<Artist, String>() {
                       @Override
                       public String call(Artist artist) {
                           String artistName;
                           if(artist.getName().contains("(")){
                               artistName = artist.getName().substring(0,artist.getName().indexOf("(")-2).replace(" ","+");
                           }else {
                               artistName = artist.getName().replace(" ", "+");
                           }
                           return artistName;
                       }
                   })
                    .flatMap(new Func1<String, Observable<Photos>>() {
                        @Override
                        public Observable<Photos> call(String artistName) {
                           return mDataManager.getPhotosObservable(artistName);
                        }
                    })
                    .toList()
                    .subscribeOn(Schedulers.io())
                    .subscribe(new Subscriber<List<Photos>>() {
                        @Override
                        public void onCompleted() {}

                        @Override
                        public void onError(Throwable e) {

                        }

                        @Override
                        public void onNext(List<Photos> objects) {
                            mDataManager.savePhotos(objects);
                        }
                    });
            }
        });
}

Answer 1

你可以这样做：

    Observable.from(artistNames)
            .map(name -> name.replace(" ", "+"))
            .flatMap(name -> googleImageAPI.loadPhotos(name))
            .toList()
            .subscribe(new Subscriber<List<Github>>() {
                @Override
                public final void onCompleted() {
                    // do nothing
                }

                @Override
                public final void onError(Throwable e) {
                    Log.e("GithubDemo", e.getMessage());
                }

                @Override
                public final void onNext(List<Github> response) {
                    mCardAdapter.addAll(response);
                }
            })

从 List 创建一个 Observable。使用 map 运算符将空格替换为加号。使用 flatMap 调用 API。使用 toList 创建所有响应的列表。然后您可以将所有带有 addAll 的响应添加到适配器。

使用 Retrofit2 迭代网络 API 调用

Iterating over network API call using Retrofit2

java

android

rx-java

rx-android