前兩篇Android RxJava的使用（一）基本用法、Android RxJava的使用（二）Action介紹了RxJava的基本用法，對Rxjava還不了解的請先看以上兩篇。這篇為大家講解RxJava中map和flatMap的使用。
參考：給 Android 開發者的 RxJava 詳解
（本文部分内容引用自該部落格）
回顧
前兩篇為大家介紹了使用RxJava列印多個字元串的方法
Observable.just("Hellow", "Wrold").subscribe(new Action1<String>() {
@Override
public void call(String s) {
Log.i(TAG, s);
}
}); 複制
這樣的例子基本沒有實際用處，隻是為大家示範如何使用Rxjava。今天就抛開這個例子。
map
在使用map之前要先說道一個接口：Func1，Func1和上一篇提到的Action1相似。Func1 和 Action的差別在于， Func1 包裝的是有傳回值的方法。
接下來就是map的用法，看代碼更直覺點；
例：得到多個Student對象中的name，儲存到nameList中
Observable.just(student1, student2, student2)
//使用map進行轉換，參數1：轉換前的類型，參數2：轉換後的類型
.map(new Func1<Student, String>() {
@Override
public String call(Student i) {
String name = i.getName();//擷取Student對象中的name
return name;//傳回name
}
})
.subscribe(new Action1<String>() {
@Override
public void call(String s) {
nameList.add(s);
}
}); 複制
可以看到Observable中原來的參數是Student對象，而最後我們需要的是name，這裡使用了map來實作這一轉換的過程。當然，map可以多次使用。
//多次使用map，想用幾個用幾個
Observable.just("Hello", "World")
.map(new Func1<String, Integer>() {//将String類型的轉化為Integer類型的哈希碼
@Override
public Integer call(String s) {
return s.hashCode();
}
})
.map(new Func1<Integer, String>() {//将轉化後得到的Integer類型的哈希碼再轉化為String類型
@Override
public String call(Integer integer) {
return integer.intValue() + "";
}
})
.subscribe(new Action1<String>() {
@Override
public void call(String s) {
Log.i(TAG, s);
}
}); 複制
flatMap
flatMap是一個比教難了解的一個轉換，在這裡先假設一個需求，需要列印多個Student所學的課程。這跟之前擷取Student的name又不同了，這裡先确定一下關系，一個Student類中隻有一個name，而一個Student卻有多門課程（Course），Student我們可以了解成這樣：
/**
* 學生類
*/
class Student {
private String name;//姓名
private List<Course> coursesList;//所修的課程
...
}
/**
* 課程類
*/
class Course {
private String name;//課程名
private String id;
...
} 複制
如果使用map來實作列印所有學生所修個課程名，實作的代碼是這樣的：
List<Student> students = new ArrayList<Student>();
students.add...
...
Action1<List<Course>> action1 = new Action1<List<Course>>() {
@Override
public void call(List<Course> courses) {
//周遊courses，輸出cuouses的name
for (int i = 0; i < courses.size(); i++){
Log.i(TAG, courses.get(i).getName());
}
}
};
Observable.from(students)
.map(new Func1<Student, List<Course>>() {
@Override
public List<Course> call(Student student) {
//傳回coursesList
return student.getCoursesList();
}
})
.subscribe(action1); 複制
可以看到，在Action1中出現了for來循環列印課程名，使用RxJava就是為了剔除這樣的嵌套結構，使得整體的邏輯性更強。這時候就可以使用flatMap了，使用flatMap實作的代碼是這樣的：
List<Student> students = new ArrayList<Student>();
students.add...
...
Observable.from(students)
.flatMap(new Func1<Student, Observable<Course>>() {
@Override
public Observable<Course> call(Student student) {
return Observable.from(student.getCoursesList());
}
})
.subscribe(new Action1<Course>() {
@Override
public void call(Course course) {
Log.i(TAG, course.getName());
}
}); 複制
這樣就實作了跟上面代碼一樣的效果，看起來有點懵？确實，flatMap了解起來有點繞，剛接觸flatMap的時候我也是懵逼一個。下面我将flatMap的示意圖，希望能幫助了解：
flatMap示意圖
由上圖可以看出Student1、Student2經過flatMap後，按順序依次經曆了Observable1、Observable2，分别轉化為Course。最後按順序得到Course1、Course2、Course3、Course4、Course5、Course6，其中1-3由Student1得到，4-6由Student2得到。
結合代碼和示意圖，是不是對flatMap有了一定的了解。
注意：FlatMap對這些Observables發射的資料做的是合并(merge)操作，是以它們可能是交錯的。也就說，傳入的順序可能跟出來的順序不一樣。
如果要保證順的的話，可以使用concatMap。
其他操作符
除了map和flatMap之外，還有其他操作符以供使用。這裡就不一一列舉他們的用法了，其他常用的操作符如下：
filter：集合進行過濾
each：周遊集合
take：取出集合中的前幾個
skip：跳過前幾個元素
更多操作符
小結
看完map、flatMap後，慢慢能看到RxJava的實際用處了。不過隻是這點功能的RxJava是遠遠不能滿足我們的需求，更多的用法我隻能在後面更新了。今天就到這裡吧！！！
以上有錯誤之處感謝指出
更多：
Android RxJava的使用（四）線程控制 —— Scheduler
參考：給 Android 開發者的 RxJava 詳解
（本文部分内容引用自該部落格）