引言
该篇文章主要是关于RxJava的变换操作符使用的代码讲解。关于常用的变换操作符共有以下几种：
- Map()
- FlatMap()
- ConcatMap()
- Buffer()
1. Map()
对被观察者发送的每一个时间都通过指定的函数处理，从而变换成另外一种事件。
下面将用Map()将事件的参数从整型变换成字符串类型为例子说明。
Observable.create(new ObservableOnSubscribe<Integer>() {
@Override
public void subscribe(ObservableEmitter<Integer> e) throws Exception {
e.onNext(1);
e.onNext(2);
e.onNext(3);
}
}).map(new Function<Integer, String>() {
@Override
public String apply(Integer integer) throws Exception {
return "使用 Map变换操作符 将事件"+integer +"的参数从 整型"+integer+"变成 字符串类型"+integer;
}
}).subscribe(new Consumer<String>() {
@Override
public void accept(String s) throws Exception {
Log.d(Constant.TAG,s);
}
});
log信息：
06-14 13:27:26.954 12356-12356/com.gjj.frame D/RxJava: 使用 Map变换操作符 将事件1的参数从 整型1变成 字符串类型1
06-14 13:27:26.954 12356-12356/com.gjj.frame D/RxJava: 使用 Map变换操作符 将事件2的参数从 整型2变成 字符串类型2
06-14 13:27:26.954 12356-12356/com.gjj.frame D/RxJava: 使用 Map变换操作符 将事件3的参数从 整型3变成 字符串类型3
2. FlatMap()
将被观察者发送事件序列进行拆分&单独转换，再合并成一个新的事件序列，最后再进行发送。
Observable.create(new ObservableOnSubscribe<Integer>() {
@Override
public void subscribe(ObservableEmitter<Integer> e) throws Exception {
e.onNext(1);
e.onNext(2);
e.onNext(3);
}
}).flatMap(new Function<Integer, ObservableSource<String>>() {
@Override
public ObservableSource<String> apply(Integer integer) throws Exception {
List<String> list = new ArrayList<>();
for (int i = 0; i < 3; i++) {
list.add("我是事件 "+integer + "拆分后的子事件"+i);
}
return Observable.fromIterable(list);
}
}).subscribe(new Consumer<String>() {
@Override
public void accept(String s) throws Exception {
Log.d(Constant.TAG,s);
}
});
log信息：
06-14 13:38:31.340 13507-13507/com.gjj.frame D/RxJava: 我是事件 1拆分后的子事件0
06-14 13:38:31.340 13507-13507/com.gjj.frame D/RxJava: 我是事件 1拆分后的子事件1
06-14 13:38:31.340 13507-13507/com.gjj.frame D/RxJava: 我是事件 1拆分后的子事件2
06-14 13:38:31.340 13507-13507/com.gjj.frame D/RxJava: 我是事件 2拆分后的子事件0
06-14 13:38:31.340 13507-13507/com.gjj.frame D/RxJava: 我是事件 2拆分后的子事件1
06-14 13:38:31.340 13507-13507/com.gjj.frame D/RxJava: 我是事件 2拆分后的子事件2
06-14 13:38:31.341 13507-13507/com.gjj.frame D/RxJava: 我是事件 3拆分后的子事件0
06-14 13:38:31.340 13507-13507/com.gjj.frame D/RxJava: 我是事件 3拆分后的子事件1
06-14 13:38:31.340 13507-13507/com.gjj.frame D/RxJava: 我是事件 3拆分后的子事件2
注：新合并生成的事件序列顺序是无序的，即与就序列发送事件的顺序无关。
3. ConcatMap()
与FlatMap()的区别在于：拆分&重新合并生成的事件序列的顺序 = 被观察者旧序列生产的顺序
Observable.create(new ObservableOnSubscribe<Integer>() {
@Override
public void subscribe(ObservableEmitter<Integer> e) throws Exception {
e.onNext(1);
e.onNext(2);
e.onNext(3);
}
}).concatMap(new Function<Integer, ObservableSource<String>>() {
@Override
public ObservableSource<String> apply(Integer integer) throws Exception {
List<String> list = new ArrayList<>();
for (int i = 0; i < 3; i++) {
list.add("我是事件 "+integer + "拆分后的子事件"+i);
}
return Observable.fromIterable(list);
}
}).subscribe(new Consumer<String>() {
@Override
public void accept(String s) throws Exception {
Log.d(Constant.TAG,s);
}
});
log信息：
06-14 13:46:12.926 13973-13973/com.gjj.frame D/RxJava: 我是事件 1拆分后的子事件0
06-14 13:46:12.926 13973-13973/com.gjj.frame D/RxJava: 我是事件 1拆分后的子事件1
06-14 13:46:12.926 13973-13973/com.gjj.frame D/RxJava:我是事件 1拆分后的子事件2
06-14 13:46:12.926 13973-13973/com.gjj.frame D/RxJava:我是事件 2拆分后的子事件0
06-14 13:46:12.926 13973-13973/com.gjj.frame D/RxJava:我是事件 2拆分后的子事件1
06-14 13:46:12.926 13973-13973/com.gjj.frame D/RxJava: 我是事件 2拆分后的子事件2
06-14 13:46:12.927 13973-13973/com.gjj.frame D/RxJava: 我是事件 3拆分后的子事件0
06-14 13:46:12.926 13973-13973/com.gjj.frame D/RxJava:我是事件 3拆分后的子事件1
06-14 13:46:12.926 13973-13973/com.gjj.frame D/RxJava:我是事件 3拆分后的子事件2
4.Buffer()
定期从被观察需要发送的事件中获取一定数量的事件&放到缓存区中，最终发送。
Observable.just(1,2,3,4,5)
.buffer(3,1)
.subscribe(new Observer<List<Integer>>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(List<Integer> value) {
Log.d(Constant.TAG,"缓存区里的事件数量 = "+value.size());
for (Integer i : value) {
Log.d(Constant.TAG,"事件 = "+value);
}
}
@Override
public void onError(Throwable e) {
Log.d(Constant.TAG,"对Error事件作出响应");
}
@Override
public void onComplete() {
Log.d(Constant.TAG,"对Complete事件作出响应");
}
});
log信息：
06-15 13:23:34.640 18281-18281/com.gjj.frame D/RxJava: 缓存区里的事件数量 = 3
06-15 13:23:34.640 18281-18281/com.gjj.frame D/RxJava: 事件 = [1, 2, 3]
06-15 13:23:34.641 18281-18281/com.gjj.frame D/RxJava: 事件 = [1, 2, 3]
06-15 13:23:34.641 18281-18281/com.gjj.frame D/RxJava: 缓存区里的事件数量 = 3
06-15 13:23:34.640 18281-18281/com.gjj.frame D/RxJava: 事件 = [2, 3, 4]
06-15 13:23:34.642 18281-18281/com.gjj.frame D/RxJava: 事件 = [2, 3, 4]
06-15 13:23:34.640 18281-18281/com.gjj.frame D/RxJava: 缓存区里的事件数量 = 3
06-15 13:23:34.640 18281-18281/com.gjj.frame D/RxJava: 事件 = [3, 4, 5]
06-15 13:23:34.642 18281-18281/com.gjj.frame D/RxJava: 事件 = [3, 4, 5]
06-15 13:23:34.640 18281-18281/com.gjj.frame D/RxJava: 缓存区里的事件数量 = 2
06-15 13:23:34.640 18281-18281/com.gjj.frame D/RxJava: 事件 = [4, 5]
06-15 13:23:34.643 18281-18281/com.gjj.frame D/RxJava: 事件 = [4, 5]
06-15 13:23:34.640 18281-18281/com.gjj.frame D/RxJava: 缓存区里的事件数量 = 1
06-15 13:23:34.640 18281-18281/com.gjj.frame D/RxJava: 事件 = [5]
06-15 13:23:34.640 18281-18281/com.gjj.frame D/RxJava: 对Complete事件作出响应
