在 RxJava2 中使用 flatMapIterable()

Question

我刚开始使用 RxJava 并尝试一个示例项目。

我想要实现的是

->获取一个对象-> 其中包含子对象列表 -> 检查子列表是否满足谓词条件 -> 如果满足

则发出子对象

这是我的 POJO

public class UpComingMovies {

@SerializedName("results")
  private List<Movies> results;
}

public class Movies {

@SerializedName("overview")
  private String overview;

@SerializedName("original_language")
  private String originalLanguage;
}

所以，据我了解，我可以使用 flatMapIterable 并将项目转换为多个可观察对象，然后使用 filter 说给我电影 originalLanguage.equals("en")

这是我尝试过的

 @GET("movie/upcoming")
Observable<UpComingMovies> getUpComingMovies(@Query("api_key") String apiKey, @Query("page") String page);

private final CompositeDisposable disposables = new CompositeDisposable();

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);

     disposables.add(RetrofitConnection.getService()
            .getUpComingMovies(Config.API_KEY, "1")
            .flatMapIterable(new Function<UpComingMovies, Iterable<Movies>>() {
                @Override
                public Iterable<Movies> apply(@NonNull UpComingMovies upComingMovies) throws Exception {
                    // no instance(s) of the type variable(s) U exist so that the Observable<U> conforms to a disposable
                    return upComingMovies.getResults();
                }
            })
            .filter(movies -> movies.getVoteCount() > 200).subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new DisposableObserver<Movies>() {
                @Override
                public void onNext(@NonNull Movies movies) {

                }

                @Override
                public void onError(@NonNull Throwable e) {

                }

                @Override
                public void onComplete() {

                }
            }));
}

但是，它不编译。 Cleary 我不知道该怎么做，感谢任何帮助

Answer 1

如果我正确理解了你的代码，你会得到一个 UpcomingMovies 类型的结果（这就是为什么你应该在这里使用 Single 而不是 Observable），然后将其展平为Movies 类型的多次排放。这就是为什么您的 subscribe 函数不起作用：它期望 UpcomingMovies 但得到 Movies.

这样的东西可能是你想要的：

@GET("movie/upcoming")
Single<UpComingMovies> getUpComingMovies(@Query("api_key") String apiKey, @Query("page") String page);

RetrofitConnection.getService()
            .getUpComingMovies(Config.API_KEY, "1")
            .flatMapIterable((UpComingMovies upComingMovies) -> { 
                return upComingMovies.getResults(); 
             })
            .filter((Movies movie) -> { 
                return movie.originalLanguage.equals("en"); 
            })
            .subscribe((Movies movie) -> { 
                Log.d("", movie.toString()); 
            });

Answer 2

它没有编译的原因是因为你返回一个可观察对象并且你的函数签名需要一个可迭代对象：

new Function<UpComingMovies, Iterable<Movies>>() {
    @Override
    public Iterable<Movies> apply(@NonNull UpComingMovies upComingMovies) throws Exception {
        // List<Movies> is iterable
        return upComingMovies.getResults();

    }
}

如果你这样修好了，那么你就可以

...flatMapIterable(...)
    .filter(new Predicate<Movies>() {
        @Override
        public boolean test(Movies movies) throws Exception {
                return movies.originalLanguage.equals("en");
        }
    })...

Answer 3

我不知道这是否正是您想要做的，但替换

return Observable.fromIterable(upComingMovies.getResults());

和

return upComingMovies.getResults();

如果你想让你的项目编译

在 RxJava2 中使用 flatMapIterable()

Using flatMapIterable() in RxJava2

android

rx-java2