3

我一直在查看 StackOverflow 和其他与 Android 相关的网站，试图掌握这一点，但我仍在苦苦挣扎。

我正在使用 Retrofit 来调用 API，如下所示：

public interface TheMovieDbApi {

@GET("genre/{type}/list")
Observable<GenresReply<Genre>> getGenreList(@Path("type") String type);

}

上面的示例返回一个包含流派列表的对象 (GenresReply)。

我需要打两次电话——一次是看电影，一次是看电视——然后结合结果。在查看了此处的其他示例后，我提出了以下建议：

    private void loadGenres() {
    List<Observable<?>> requests = new ArrayList<>();

    requests.add(api.getGenreList("movie"));
    requests.add(api.getGenreList("tv"));

    //Now what?
}

我迷失了下一步。我见过使用 Observable.concat()、.flatMap() 和 .zip() 然后订阅输出的示例，但我对 RxJava 不够熟悉，不知道下一步该做什么。

TL;DR 如何进行两次 API 调用并从每个响应/组合的流派列表中提取流派列表？

解决方案

感谢John和masp的评论，这就是我想出的：

    private void loadGenres() {
    Observable.zip(api.getGenreList(MOVIE_GENRES), api.getGenreList(SHOW_GENRES),
            new BiFunction<GenresReply<Genre>, GenresReply<Genre>, List<Genre>>() {
                @Override
                public List<Genre> apply(GenresReply<Genre> movieReply, GenresReply<Genre> showReply)
                        throws Exception {
                    List<Genre> genreList = new ArrayList<>();
                    genreList.addAll(movieReply.getGenres());
                    genreList.addAll(showReply.getGenres());

                    return genreList;
                }
            }).subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Observer<List<Genre>>() {
                @Override
                public void onSubscribe(@NonNull Disposable d) {

                }

                @Override
                public void onNext(@NonNull List<Genre> genres) {
                    DatabaseUtils.insertGenres(genres, ListActivity.this);
                }

                @Override
                public void onError(@NonNull Throwable e) {
                    mSharedPreferences.edit().putBoolean(FIRST_RUN, true).apply();
                }

                @Override
                public void onComplete() {

                }
            });
}
4

1 回答 1

1

您应该能够执行以下操作：

    Observable.zip(api.getGenreList("movie", api.getGenreList("tv", (movieInfo, tvInfo) -> Pair.create(movieInfo, tvInfo)).subscribe(movieTvPair -> {

    })
于 2017-09-26T14:08:04.800 回答