資訊專(zhuān)欄INFORMATION COLUMN
摘要：從這一章開(kāi)始，我們開(kāi)始聊聊中的操作符，后面我將用三章的篇幅來(lái)分別介紹轉(zhuǎn)換類(lèi)操作符過(guò)濾類(lèi)操作符組合類(lèi)操作符這一章我們主要講講轉(zhuǎn)換類(lèi)操作符。函數(shù)同樣也是做轉(zhuǎn)換的，但是作用卻不一樣。
轉(zhuǎn)載請(qǐng)注明出處：https://zhuanlan.zhihu.com/p/21926591
RxJava系列1(簡(jiǎn)介)
RxJava系列2(基本概念及使用介紹)
RxJava系列3(轉(zhuǎn)換操作符)
RxJava系列4(過(guò)濾操作符)
RxJava系列5(組合操作符)
RxJava系列6(從微觀角度解讀RxJava源碼)
RxJava系列7(最佳實(shí)踐)
前面兩篇文章中我們介紹了RxJava的一些基本概念和RxJava最簡(jiǎn)單的用法。從這一章開(kāi)始，我們開(kāi)始聊聊RxJava中的操作符Operators，后面我將用三章的篇幅來(lái)分別介紹：
轉(zhuǎn)換類(lèi)操作符
過(guò)濾類(lèi)操作符
組合類(lèi)操作符
這一章我們主要講講轉(zhuǎn)換類(lèi)操作符。所有這些Operators都作用于一個(gè)可觀測(cè)序列，然后變換它發(fā)射的值，最后用一種新的形式返回它們。概念實(shí)在是不好理解，下面我們結(jié)合實(shí)際的例子一一介紹。
Mapmap(Func1)函數(shù)接受一個(gè)Func1類(lèi)型的參數(shù)(就像這樣map(Func1 func)),然后吧這個(gè)Func1應(yīng)用到每一個(gè)由Observable發(fā)射的值上，將發(fā)射的只轉(zhuǎn)換為我們期望的值。這種狗屁定義我相信你也聽(tīng)不懂，我們來(lái)看一下官方給出的原理圖：
假設(shè)我們需要將一組數(shù)字裝換成字符串，我們可以通過(guò)map這樣實(shí)現(xiàn)：
Observable.just(1, 2, 3, 4, 5)
.map(new Func1() {
@Override
public String call(Integer i) {
return "This is " + i;
}
}).subscribe(new Action1() {
@Override
public void call(String s) {
System.out.println(s);
}
});
FlatMapFunc1構(gòu)造函數(shù)中的兩個(gè)參數(shù)分別是Observable發(fā)射值當(dāng)前的類(lèi)型和map轉(zhuǎn)換后的類(lèi)型，上面這個(gè)例子中發(fā)射值當(dāng)前的類(lèi)型是Integer,轉(zhuǎn)換后的類(lèi)型是String。
flatMap(Func1)函數(shù)同樣也是做轉(zhuǎn)換的，但是作用卻不一樣。flatMap不太好理解，我們直接看例子（我們公司是個(gè)房產(chǎn)平臺(tái)，那我就拿房子舉例）：假設(shè)我們有一組小區(qū)數(shù)據(jù)Community[] communites,現(xiàn)在我們要輸出每個(gè)小區(qū)的名字；我們可以這樣實(shí)現(xiàn):
Observable.from(communities)
.map(new Func1() {
@Override
public String call(Community community) {
return community.name;
}
})
.subscribe(new Action1() {
@Override
public void call(String name) {
System.out.println("Community name : " + name);
}
});
現(xiàn)在我們需求有變化，需要打印出每個(gè)小區(qū)下面每一套房子的價(jià)格。于是我可以這樣實(shí)現(xiàn)：
Community[] communities = {};
Observable.from(communities)
.subscribe(new Action1() {
@Override
public void call(Community community) {
for (House house : community.houses) {
System.out.println("House price : " + house.price);
}
}
});
如果我不想在Subscriber中使用for循環(huán)，而是希望Subscriber中直接傳入單個(gè)的House對(duì)象呢？用map()顯然是不行的，因?yàn)閙ap()是一對(duì)一的轉(zhuǎn)化，而我現(xiàn)在的要求是一對(duì)多的轉(zhuǎn)化。那么我們可以使用flatMap()把一個(gè)Community轉(zhuǎn)化成多個(gè)House。
Observable.from(communities)
.flatMap(new Func1>() {
@Override
public Observable call(Community community) {
return Observable.from(community.houses);
}
})
.subscribe(new Action1() {
@Override
public void call(House house) {
System.out.println("House price : " + house.price);
}
});
從前面的例子中我們發(fā)現(xiàn)，flatMap()和map()都是把傳入的參數(shù)轉(zhuǎn)化之后返回另一個(gè)對(duì)象。但和map()不同的是，flatMap()中返回的是Observable對(duì)象，并且這個(gè)Observable對(duì)象并不是被直接發(fā)送到 Subscriber的回調(diào)方法中。
flatMap(Func1)的原理是這樣的：
將傳入的事件對(duì)象裝換成一個(gè)Observable對(duì)象；
這是不會(huì)直接發(fā)送這個(gè)Observable, 而是將這個(gè)Observable激活讓它自己開(kāi)始發(fā)送事件；
每一個(gè)創(chuàng)建出來(lái)的Observable發(fā)送的事件，都被匯入同一個(gè)Observable，這個(gè)Observable負(fù)責(zé)將這些事件統(tǒng)一交給Subscriber的回調(diào)方法。
這三個(gè)步驟，把事件拆成了兩級(jí)，通過(guò)一組新創(chuàng)建的Observable將初始的對(duì)象『鋪平』之后通過(guò)統(tǒng)一路徑分發(fā)了下去。而這個(gè)『鋪平』就是flatMap()所謂的flat。
最后我們來(lái)看看flatMap的原理圖：
ConcatMapconcatMap(Func1)解決了flatMap()的交叉問(wèn)題，它能夠把發(fā)射的值連續(xù)在一起，就像這樣：
flatMapIterableflatMapIterable(Func1)和flatMap()幾乎是一樣的，不同的是flatMapIterable()它轉(zhuǎn)化的多個(gè)Observable是使用Iterable作為源數(shù)據(jù)的。
Observable.from(communities)
.flatMapIterable(new Func1>() {
@Override
public Iterable call(Community community) {
return community.houses;
}
})
.subscribe(new Action1() {
@Override
public void call(House house) {
}
});
SwitchMap
switchMap(Func1)和flatMap(Func1)很像，除了一點(diǎn)：每當(dāng)源Observable發(fā)射一個(gè)新的數(shù)據(jù)項(xiàng)（Observable）時(shí)，它將取消訂閱并停止監(jiān)視之前那個(gè)數(shù)據(jù)項(xiàng)產(chǎn)生的Observable，并開(kāi)始監(jiān)視當(dāng)前發(fā)射的這一個(gè)。
Scanscan(Func2)對(duì)一個(gè)序列的數(shù)據(jù)應(yīng)用一個(gè)函數(shù)，并將這個(gè)函數(shù)的結(jié)果發(fā)射出去作為下個(gè)數(shù)據(jù)應(yīng)用合格函數(shù)時(shí)的第一個(gè)參數(shù)使用。
我們來(lái)看個(gè)簡(jiǎn)單的例子：
Observable.just(1, 2, 3, 4, 5)
.scan(new Func2() {
@Override
public Integer call(Integer integer, Integer integer2) {
return integer + integer2;
}
}).subscribe(new Action1() {
@Override
public void call(Integer integer) {
System.out.print(integer+“ ”);
}
});
輸出結(jié)果為：
1 3 6 10 15GroupBy
groupBy(Func1)將原始Observable發(fā)射的數(shù)據(jù)按照key來(lái)拆分成一些小的Observable，然后這些小Observable分別發(fā)射其所包含的的數(shù)據(jù)，和SQL中的groupBy類(lèi)似。實(shí)際使用中，我們需要提供一個(gè)生成key的規(guī)則（也就是Func1中的call方法），所有key相同的數(shù)據(jù)會(huì)包含在同一個(gè)小的Observable中。另外我們還可以提供一個(gè)函數(shù)來(lái)對(duì)這些數(shù)據(jù)進(jìn)行轉(zhuǎn)化，有點(diǎn)類(lèi)似于集成了flatMap。
單純的文字描述和圖片解釋可能難以理解，我們來(lái)看個(gè)例子：假設(shè)我現(xiàn)在有一組房源List
