話說通過前三篇文章的講解鸭叙，想必你對RxJava也有了深刻的認(rèn)識吧闯第，啥，你說沒有旺聚？那回去看看织阳！那么今天我們來分析RxJava最牛逼的地方。睜大眼睛看看哦砰粹，不管你濕沒濕唧躲，反正我已經(jīng)濕了。
一碱璃、API
RxJava提供了對事件序列進(jìn)行變換的支持弄痹，這是它的核心功能之一，也是大多數(shù)人說RxJava好用的最大原因嵌器。所謂變換界酒，就是將事件序列中的對象或整個序列進(jìn)行加工處理，轉(zhuǎn)換成不同的事件或事件序列嘴秸。
首先看一個<code>map()</code>的例子：
Observable.just("images/logo.png") // 輸入類型 String
.map(new Func1<String, Bitmap>() {
@Override
public Bitmap call(String filePath) { // 參數(shù)類型 String
return getBitmapFromPath(filePath); // 返回類型 Bitmap
}
})
.subscribe(new Action1<Bitmap>() {
@Override
public void call(Bitmap bitmap) { // 參數(shù)類型 Bitmap
showBitmap(bitmap);
}
});
這里出現(xiàn)了一個叫做 Func1的類毁欣。它和 Action1非常相似庇谆，也是 RxJava 的一個接口，用于包裝含有一個參數(shù)的方法凭疮。 Func1和Action的區(qū)別在于饭耳， Func1包裝的是有返回值的方法。另外执解，和 ActionX一樣寞肖， FuncX也有多個，用于不同參數(shù)個數(shù)的方法衰腌。FuncX和 ActionX的區(qū)別在 FuncX包裝的是有返回值的方法新蟆。
可以看到，<code>map()</code>方法將參數(shù)中的<code>String</code>對象轉(zhuǎn)換成了一個Bitmap對象后返回右蕊，經(jīng)過<code>map()</code>方法后琼稻，事件的參數(shù)類型也由<code>String</code>轉(zhuǎn)為<code>Bitmap</code>。這種直接變換對象并返回的饶囚，就是最常見的變換帕翻。不過RxJava的變換遠(yuǎn)不止這樣，它不僅可以針對事件對象萝风，還可以針對整個事件隊(duì)列嘀掸，是不是好屌的樣子啊规惰？
- <code>map()</code>:事件對象的直接變換睬塌。示意圖如下
- <code>flatMap()</code>:FlatMap將一個發(fā)射數(shù)據(jù)的Observable變換為多個Observables，然后將它們發(fā)射的數(shù)據(jù)合并后放進(jìn)一個單獨(dú)的Observable.
這是一個很有用但非常難理解的變換歇万，因此我決定花多些篇幅來介紹它衫仑。 首先假設(shè)這么一種需求：假設(shè)有一個數(shù)據(jù)結(jié)構(gòu)『學(xué)生』，現(xiàn)在需要打印出一組學(xué)生的名字堕花。實(shí)現(xiàn)方式很簡單：
Student[] students = ...;
Subscriber<String> subscriber = new Subscriber<String>() {
@Override
public void onNext(String name) {
Log.d(tag, name);
}
...
};
Observable.from(students)
.map(new Func1<Student, String>() {
@Override
public String call(Student student) {
return student.getName();
}
})
.subscribe(subscriber);
很簡單。那么再假設(shè)：如果要打印出每個學(xué)生所需要修的所有課程的名稱呢粥鞋？（需求的區(qū)別在于缘挽，每個學(xué)生只有一個名字，但卻有多個課程呻粹。）首先可以這樣實(shí)現(xiàn)：
Student[] students = ...;
Subscriber<Student> subscriber = new Subscriber<Student>() {
@Override
public void onNext(Student student) {
List<Course> courses = student.getCourses();
for (int i = 0; i < courses.size(); i++) {
Course course = courses.get(i);
Log.d(tag, course.getName());
}
}
...
};
Observable.from(students)
.subscribe(subscriber);
依然很簡單壕曼。那么如果我不想在 Subscriber中使用 for 循環(huán)，而是希望 Subscriber中直接傳入單個的 Course對象呢（這對于代碼復(fù)用很重要）等浊？用 map()顯然是不行的腮郊，因?yàn)?map()是一對一的轉(zhuǎn)化，而我現(xiàn)在的要求是一對多的轉(zhuǎn)化筹燕。那怎么才能把一個 Student 轉(zhuǎn)化成多個 Course 呢轧飞？這個時候就要用flatMap()了：
Student[] students = ...;
Subscriber<Course> subscriber = new Subscriber<Course>() {
@Override
public void onNext(Course course) {
Log.d(tag, course.getName());
}
...
};
Observable.from(students)
.flatMap(new Func1<Student, Observable<Course>>() {
@Override
public Observable<Course> call(Student student) {
return Observable.from(student.getCourses());
}
})
.subscribe(subscriber);
從上面看出衅鹿，<code>flatMap()</code>和<code>map()</code>有一個共同點(diǎn)：它也是把傳入的參數(shù)轉(zhuǎn)化之后返回另一個對象。但不同的是过咬，<code>flatMap()</code>返回的是<code>Observable</code>對象,并且這個<code>Observable</code>對象并不是直接發(fā)給<code>Subscriber</code>的回調(diào)方法中大渤。
flatMap()的原理是這樣的：
1. 使用傳入的事件對象創(chuàng)建一個 Observable對象；
2. 并不發(fā)送這個 Observable, 而是將它激活掸绞，于是它開始發(fā)送事件泵三；
3. 每一個創(chuàng)建出來的 Observable 發(fā)送的事件，都被匯入同一個 Observable衔掸，而這個 Observable 負(fù)責(zé)將這些事件統(tǒng)一交給 Subscriber的回調(diào)方法烫幕。
這三個步驟，把事件拆成了兩級敞映，通過一組新創(chuàng)建 Observable將初始的對象『鋪平』之后通過統(tǒng)一路徑分發(fā)了下去较曼。而這個『鋪平』就是 flatMap() 所謂的 flat。
<code>flatMap()</code>示意圖：
二驱显、變換的原理：lift()
這些變換雖然功能各有不同诗芜，但實(shí)質(zhì)上都是針對事件序列的處理和再發(fā)送。而在 RxJava 的內(nèi)部埃疫，它們是基于同一個基礎(chǔ)的變換方法：<code>lift(Operator)</code>伏恐。首先看一下 <code>lift()</code> 的內(nèi)部實(shí)現(xiàn)（僅核心代碼）
// 注意：這不是 lift() 的源碼，而是將源碼中與性能栓霜、兼容性翠桦、擴(kuò)展性有關(guān)的代碼剔除后的核心代碼。
// 如果需要看源碼胳蛮，可以去 RxJava 的 GitHub 倉庫下載销凑。
public <R> Observable<R> lift(Operator<? extends R, ? super T> operator) {
return Observable.create(new OnSubscribe<R>() {
@Override
public void call(Subscriber subscriber) {
Subscriber newSubscriber = operator.call(subscriber);
newSubscriber.onStart();
onSubscribe.call(newSubscriber);
}
});
}
它生成一個新的<code>Observable</code>并返回，而且創(chuàng)建新<code>Observable</code>所用的參數(shù)<code>OnSubscribe</code>的回調(diào)方法<code>call()</code>
中實(shí)現(xiàn)竟然看起來和前面講的<code>Observable.subscribe()</code>一樣仅炊！然而它們并不一樣喲~不一樣的地方關(guān)鍵就在于第二行onSubscribe.call(subscriber)中的 onSubscribe所指代的對象不同斗幼。
*subscribe()中的 onSubscribe指的是 Observable中的 onSubscribe對象，這個沒有問題抚垄，但是 lift()之后的情況就復(fù)雜了點(diǎn)蜕窿。
*當(dāng)含有l(wèi)ift()時：
1、<code>lift()</code>創(chuàng)建了一個Observable后呆馁，加上之前原始的Observable桐经，已經(jīng)有兩個Observable對象了.
2、同樣浙滤，新Observable里的OnSubscribe加上原始的OnSubscribe阴挣，也有兩個OnSubscribe;
3、當(dāng)調(diào)用lift()后的subscribe()時纺腊，使用的是lift()所返回的新Observable,于是它被所觸發(fā)的onSubscribe.call(subscriber)也是新Observable中的OnSubscribe;
4畔咧、新OnSubscribe的call()方法中的onSubscribe茎芭，就是指原始Observable中的OnSubscribe.在這個 call()方法里，新 OnSubscribe 利用 operator.call(subscriber)
生成了一個新的 Subscriber（Operator 就是在這里盒卸，通過自己的call() 方法將新 Subscriber 和原始 Subscriber 進(jìn)行關(guān)聯(lián)骗爆，并插入自己的『變換』代碼以實(shí)現(xiàn)變換），然后利用這個新Subscriber 向原始 Observable進(jìn)行訂閱蔽介。
這樣就實(shí)現(xiàn)了 lift()過程摘投，有點(diǎn)像一種代理機(jī)制，通過事件攔截和處理實(shí)現(xiàn)事件序列的變換虹蓄。
精簡掉細(xì)節(jié)的話犀呼，也可以這么說：在 Observable 執(zhí)行了 lift(Operator) 方法之后，會返回一個新的 Observable薇组，這個新的Observable會像一個代理一樣外臂，負(fù)責(zé)接收原始的 Observable發(fā)出的事件，并在處理后發(fā)送給 Subscriber律胀。
同時可以看圖：
此外宋光，RxJava提供很多變化操作符如Buffer、FlatMap炭菌、Map罪佳、GroupBy、Scan黑低、Window赘艳。想具體了解的查看這里。
