Map与FlatMap
map
-
基础概念
map 是 RxJava中 最常见的变换操作符之一。
它的作用就是对 Observable 发送的每一个事件应用一个函数, 使得每一个事件都按照指定的函数去变化。
通俗的说，就是把被观察者发送事件里面的对象转换成你需要的对象，然后发送给观察者
-
看图识字
map把 Observable 里的圆形一个个转换成方形，然后发射出去给 observer
-
代码示例
比如说现在我需要把一个图片连接下载到bitmap对象然后设置图片
mObservable.map(new Func1<String, Bitmap>() { @Override public Bitmap call(String url) { return getBitmapFormUrl(url); } }).subscribe(new Action1<Bitmap>() { @Override public void call(Bitmap bitmap) { // 参数类型 Bitmap imageView.setImageBitmap(bitmap); } }); //Func1方法里，第一个泛型是接受转换的数据类型，第二个参数是转换后的数据类型
flatMap
-
基础概念
FlatMap 将一个发送事件的上游 Observable 变换为多个发送事件的 Observables ，然后将它们发射的事件合并后放进一个单独的 Observable 里
-
看图识字
Observable 发送了3个事件，分别是圆形的1、2、3
flatMap 将3个圆形事件转换成发送三角形和正方形的事件，生成一个新的 Observable
动作分解
-
代码示例
现在我们有一个需求，用户需要先请求一个接口获得 token ，然后根据 token 再请求数据获取 user 信息，让我们用示例代码试试吧。
//TODO 1.声明一个获取token的观察者 Observable<String> getTokenObservable = .....;
//TODO 2.将获取token的观察者转换成获取user的观察者
Observable<UserAdapter> getUserObservable = getTokenObservable.flatMap(new Func1<String, Observable<User>>() {
@Override
public Observable<User> call(String token) {
return getUserObservable(token);//这里有一个获取UserObservable的方法
}
});
//TODO 3.观察者订阅获取user的被观察者
getUserObservable.subscribe(new Action1<User>() {
@Override
public void call(User user) {
//成功拿到user
}
});
//动作合并，更优雅的写法
getTokenObservable.flatMap(new Func1<String, Observable<User>>() {
@Override
public Observable<User> call(String token) {
return getUserObservable(token);
}
}).subscribe(new Action1<User>() {
@Override
public void call(User userAdapter) {
//成功拿到user
}
});
```
-
特别声明
flatMap 并不保证事件的顺序，就是说上面的图刚开始发送123转换后，观察者接收到的可能就是213了。如果需要保证事件顺序可以使用 concatMap
