從入門到精通：RxJava FlatMap 的使用指南

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>() {
            @Override
            public ObservableSource apply(@NonNull String s) throws Exception {
                String[] words = s.split(" ");
                return Observable.fromArray(words);
            }
        })
        .subscribe(new Consumer() {
            @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> requestPeople() {
        return mApiService.getPeople()
                .flatMap(new Function<PeopleResponse, ObservableSource<List>>() {
                    @Override
                    public ObservableSource<List> apply(@NonNull PeopleResponse peopleResponse) throws Exception {
                        List people = peopleResponse.getPeople();
                        return Observable.just(people);
                    }
                });
    }

}

以上代碼使用了Retrofit對於網絡請求的封裝，我們直接調用getPeople()方法獲取網絡請求的結果。

我們使用flatMap操作符將PeopleResponse對象轉化為一個List結果，最終返回一個PersonObservable集合。

接下來我們可以在其他地方使用我們的網絡請求方法：

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

在這裡，我們重新設置數據源的線程環境，將其放在後台執行，然後在主線程中更新UI界面。

四、結論

FlatMap操作符是 RxJava 中一個非常實用的操作符，可以將元素的類型從一個類型轉換為另一個類型，並將多個元素重新組合成一個事件流。我們可以使用 flatMap 操作符來實現複雜的網絡請求等操作。