原文連結

在第1部分中，我討論了RxJava的基本結構，並介紹了map（）operator。但是，如果你仍然沒有意願去使用RxJava，我可以理解。因為還你沒有大量的工作。但是這將迅速改變–RxJava的大部分功能是包含在在框架中的所有Operators。

讓我們通過一個例子向你介紹更多的Operators。

假設

假設我這樣一個方法：

// Returns a List of website URLs based on a text search
Observable<List<String>> query(String text); 

我想做一個健壯的系統來搜尋文字和顯示結果。鑑於我們從上一篇文章中知道的，這是可能想出來的：

query("Hello, world!")
    .subscribe(urls -> {
        for (String url : urls) {
            System.out.println(url);
        }
    });

這個答案令人非常不滿意，因為我失去了轉換資料流的能力。如果我想修改每個URL，我必須在Subscriber去做，而沒有去使用強大的map()處理。

我可以從urls - > urls建立一個map（），但是每個map（）呼叫都會有一個for-each迴圈。

希望之光

如下的方法，Observable.from（）會遍歷集合

Observable.from("url1", "url2", "url3")
    .subscribe(url -> System.out.println(url));

結合上面的需求

query("Hello, world!")
    .subscribe(urls -> {
        Observable.from(urls)
            .subscribe(url -> System.out.println(url));
    });

確實避免了for-each迴圈，但是一團糟，有多個巢狀訂閱！除了醜陋和難以修改，它也打破了RxJava的一些關鍵但尚未發現的功能。

更好的方案

flatMap()

Observable.flatMap（）獲取一個Observable例項，並返回另一個Observable的例項。以下是解決這個問題的方法：

query("Hello, world!")
    .flatMap(new Func1<List<String>, Observable<String>>() {
        @Override
        public Observable<String> call(List<String> urls) {
            return Observable.from(urls);
        }
    })
    .subscribe(url -> System.out.println(url));

flatMap（）很奇怪，對吧？為什麼它返回另一個Observable？這裡的關鍵概念是返回的新Observable是被訂閱的。它並沒有接收List< String > ,它獲得一系列由Observable.from（）返回的單個字串。

甚至更好

flatMap（）可以返回任何它想要的Observable

假設我有第二種方法：

// Returns the title of a website, or null if 404
Observable<String> getTitle(String URL);

現在我要列印每個收到的網站的標題，而不是列印網址。但是有一些問題：我的方法一次只處理一個URL，它不返回一個String，它返回一個發出String的Observable。

使用flatMap（），解決這個問題很容易;在將URL列表拆分為單獨的專案後，我可以在flatMap（）中為每個URL使用getTitle（），然後再到Subscriber：

query("Hello, world!")
    .flatMap(urls -> Observable.from(urls))
    .flatMap(new Func1<String, Observable<String>>() {
        @Override
        public Observable<String> call(String url) {
            return getTitle(url);
        }
    })
    .subscribe(title -> System.out.println(title));

提升

除了map和flatMap兩種operators，還有很多。對上面的操作還可以改進。如果URL是404的時候，getTitle（）返回null。

• 我們不想輸出“null”，則可以進行過濾

query("Hello, world!")
    .flatMap(urls -> Observable.from(urls))
    .flatMap(url -> getTitle(url))
    .filter(title -> title != null)
    .subscribe(title -> System.out.println(title));

filter 的引數和結果是同一個值，它僅僅對boolean進行判斷。

• 最多顯示5個結果，可以這樣做

query("Hello, world!")
    .flatMap(urls -> Observable.from(urls))
    .flatMap(url -> getTitle(url))
    .filter(title -> title != null)
    .take(5)
    .subscribe(title -> System.out.println(title));

take()用於指定最多數量。

• 儲存標題到本地

query("Hello, world!")
    .flatMap(urls -> Observable.from(urls))
    .flatMap(url -> getTitle(url))
    .filter(title -> title != null)
    .take(5)
    .doOnNext(title -> saveTitle(title))
    .subscribe(title -> System.out.println(title));

doOnNext() 可以新增其他動作，針對每個Item。