RxJava 學習筆記二

Observable.from()

它接收一個集合作為輸入，然後每次輸出一個元素給subscriber：

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

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)); 
           

輸入的是

List<String>

，傳回的是

Observable<String>

了解flatMap的關鍵點在于，flatMap輸出的新的Observable正是我們在Subscriber想要接收的。現在Subscriber不再收到List，而是收到一些列單個的字元串，就像Observable.from()的輸出一樣。

filter

輸入和輸出相同的元素，會過濾掉那些不滿足條件的

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