从入门到精通：RxJava FlatMap 的使用指南

发布时间：2023-05-19

RxJava（ReactiveX）是一个以响应式编程为核心的库，可以简单有效地处理异步事件流。

一、FlatMap 的作用是什么？

在 RxJava 中，flatMap 操作符是将事件序列中的元素进行整合和拆分的操作符。在输入一个事件流时，flatMap 操作符将每一个事件拆分成多个流，并将这些流重新组合成一个新的输出流。 举个例子，如果原始事件流里面有两个数据，分别是String类型的"hello,world" 和 "say hi to RxJava"，flatMap 操作符可以将这两个事件里面的单词分别拆分成单独的事件，然后重新组合成一个新的事件流，例如"hello", "world", "say", "hi", "to", "RxJava"。

二、如何使用 FlatMap？

下面是一个使用 flatMap 操作符的例子：

Observable.just("hello,world", "say hi to RxJava")
        .flatMap(new Function<String, ObservableSource<String>>() {
            @Override
            public ObservableSource<String> apply(@NonNull String s) throws Exception {
                String[] words = s.split(" ");
                return Observable.fromArray(words);
            }
        })
        .subscribe(new Consumer<String>() {
            @Override
            public void accept(@NonNull String s) throws Exception {
                System.out.println(s);
            }
        });

首先我们创建一个Observable对象，它会发送两个字符串元素，然后我们使用flatMap()函数将每个字符串拆分为单独的单词，然后返回一个Observable对象。 在我们的例子中，flatMap()函数的输出Observable的类型仍然是String类型的，这表示拆分后的单词仍然是字符串类型。 最后通过调用subscribe()函数来订阅结果并打印每个单词。

三、如何使用 FlatMap 实现网络请求？

我们可以使用RxJava和Retrofit联合使用来完成类似网络请求的操作。下面的示例代码中，我们假设我们的网络请求返回了一个包含多个人员的对象，我们使用 flatMap操作符将其转化为一个 PersonObservable 集合。

public class Network {
    private ApiService mApiService;
    public Network() {
        Retrofit retrofit = new Retrofit.Builder()
                .baseUrl(ApiService.BASE_URL)
                .addConverterFactory(GsonConverterFactory.create())
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                .build();
        mApiService = retrofit.create(ApiService.class);
    }
    public Observable<List<Person>> requestPeople() {
        return mApiService.getPeople()
                .flatMap(new Function<PeopleResponse, ObservableSource<List<Person>>>() {
                    @Override
                    public ObservableSource<List<Person>> apply(@NonNull PeopleResponse peopleResponse) throws Exception {
                        List<Person> people = peopleResponse.getPeople();
                        return Observable.just(people);
                    }
                });
    }
}

以上代码使用了Retrofit对于网络请求的封装，我们直接调用getPeople()方法获取网络请求的结果。 我们使用flatMap操作符将PeopleResponse对象转化为一个List<Person>结果，最终返回一个PersonObservable集合。 接下来我们可以在其他地方使用我们的网络请求方法：

Network network = new Network();
network.requestPeople()
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Consumer<List<Person>>() {
            @Override
            public void accept(List<Person> people) throws Exception {
                //更新UI界面
            }
        });

在这里，我们重新设置数据源的线程环境，将其放在后台执行，然后在主线程中更新UI界面。

四、结论

FlatMap操作符是 RxJava 中一个非常实用的操作符，可以将元素的类型从一个类型转换为另一个类型，并将多个元素重新组合成一个事件流。我们可以使用 flatMap 操作符来实现复杂的网络请求等操作。

推荐文章