1.concat、merge概述
-
concat将两个发射器合并成一个发射器, 依次发送，发送完一个再接着发送第二个。如下图所示
concat.png -
marge合并多个Observables的发射物， Merge 可能会让合并的Observables发射的数据交错，这也就是和concat的较大区别(挨个发送)
merge.png
由上图即可理解，不用等到 发射器 A 发送完所有的事件再进行发射器 B 的发送，他们是可以参杂交互发射事件。
其他
concat（） /concatArray（）的区别：
concat（）组合被观察者数量<=4,concatArray()组合被观察者>4
merge（）/mergeArray（）的区别
merge（）组合被观察者数量≤4个,mergeArray（）则可＞4个
应用
- 从磁盘 / 内存 /网络缓存中获取缓存数据
(1)设置第1个Observable：检查内存缓存是否有该数据的缓存
// 该2变量用于模拟内存缓存 & 磁盘缓存中的数据
String memoryCache = null;
String diskCache = "从磁盘缓存中获取数据";
Observable<String> memory = Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> emitter) throws Exception {
// 先判断内存缓存有无数据
if (memoryCache != null) {
// 若有该数据，则发送
emitter.onNext(memoryCache);
} else {
// 若无该数据，则直接发送结束事件
emitter.onComplete();
}
}
});
(2)设置第2个Observable：检查磁盘缓存是否有该数据的缓存
Observable<String> disk = Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> emitter) throws Exception {
// 先判断磁盘缓存有无数据
if (diskCache != null) {
// 若有该数据，则发送
emitter.onNext(diskCache);
} else {
// 若无该数据，则直接发送结束事件
emitter.onComplete();
}
}
});
(3)设置第3个Observable：通过网络获取数据
Observable<String> network = Observable.just("从网络中获取数据");
(4)通过concat（） 和 firstElement（）操作符实现缓存功能
- 通过concat（）合并memory、disk、network 3个被观察者的事件（即检查内存缓存、磁盘缓存 & 发送网络请求）并将它们按顺序串联成队列
- 通过firstElement()，从串联队列中取出并发送第1个有效事件（Next事件），即依次判断检查memory、disk、network
Observable.concat(memory, disk, network)
.firstElement()
.subscribe(new Consumer<String>() {
@Override
public void accept( String s) throws Exception {
Log.d(TAG,"最终获取的数据来源 = "+ s);
}
});
本例的逻辑为：
a. firstElement()取出第1个事件 = memory，即先判断内存缓存中有无数据缓存；当memoryCache = null，所以发送结束事件（视为无效事件）
b. 继续取出第2个事件 = disk，即判断磁盘缓存中有无数据缓存：当diskCache ≠ null，即磁盘缓存中有数据，所以发送Next事件（有效事件）
c. 即firstElement()已发出第1个有效事件（disk事件），就停止判断
