java - 从 Observable 获取数组的值

Question

我有一个Observable<MoviesResponse> 。我的MovieResponse类包含 getResults()返回 List<Result> 的方法。这个 Result 类有一个 getTitle()返回字符串的方法。我要调用getTitle()我所有的方法Result对象获取我的电影的所有标题。

我使用 foreach 循环通过下面的代码实现了这一点，但我认为有更好的方法通过链接 RxJava 运算符来实现此目的，我只是无法弄清楚......

订阅:

Observable<MoviesResponse> moviesResponseObservable = apiService.getTopRatedMoviesObservable(API_KEY);

subscription = moviesResponseObservable
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Observer<MoviesResponse>() {
                    @Override
                    public void onCompleted() {

                    }

                    @Override
                    public void onError(Throwable e) {

                    }

                    @Override
                    public void onNext(MoviesResponse moviesResponse) {
                        List<Result> results = moviesResponse.getResults();
                        for (Result r:results) {
                            Log.d(LOG_TAG,r.getTitle());
                        }
                    }
                });

界面:

public interface ApiService {           
    @GET("movie/top_rated")
    Observable<MoviesResponse> getTopRatedMoviesObservable(@Query("api_key") String apiKey);
}

Answer 1

您可以使用 flatmap将您的可观察值转换为 Observable<Result>然后使用 map把它变成Observable<String> ，然后您可以订阅。

moviesReponseObservable
    .subscribeOn(Schedulers.io())
    .flatMapIterable(new Function<MoviesResponse, Iterable<Result>>() {
        @Override
        public Iterable<Result> apply(@NonNull MoviesResponse moviesResponse) throws Exception {
            return moviesResponse.getResults();
        }
    })
    .map(new Function<Result, String>() {
        @Override
        public String apply(@NonNull Result result) throws Exception {
            return result.getTitle();
        }
    })
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(new Observer<String>() {

        @Override
        public void onNext(String s) {
            Log.d("TAG", s);
        }

        /* ... */    

    });