RxJava很火，网络上对于它的文章非常多，这是我学习的一点笔记，也许可以帮助他人理解一点。
一开始的接触，如苍蝇叮无缝的蛋，认识久了，你会感觉很熟悉。
定义什么的，在给 Android 开发者的 RxJava 详解里面介绍得相当好。
RxJava文档中文版
大头鬼RxJava
RxJava的操作符有：
flatMap()Buffer()filter()take()- ...
- 甚至自定义操作符
1.map
对Observable发射的每一项数据应用一个函数，执行变换操作
下面这个例子是将Charecter类转换成Letter类，这样下游的操作得到的是Letter类型的信息了
map(new Func1<Character, Letter>() {
@Override
public Letter call(Character character) {
return new Letter(character);
}
})
2.flatMap
Observable.flatMap()接收一个Observable的输出作为输入，同时输出另外一个Observable。
这里是引用于大头鬼大神的原话。
作用：转换输入输出流，把RxJava的整个工作流程看成一条生产线，flatMap()则可以看成是该生产线上的一个加工机器，负责将输入的一类数据转换成下个步骤所需要的另一类数据（这里的类不是OO中类的概念，仅仅是说明输入和输出是不同的，如果是相同的那就没有必要加工啦）。
例子：我们现在的数据是一个String[]类型的，原本我们就直接使用这个类型的数据没有问题，后来需求改了，需要使用的是String[]中的String了。
//原本的代码
//test RxJava
public void Method(){
String[] strs = new String[]{"i","am","a","boy","!"};
Observable<String[]> ob = Observable.just(strs);
//消费者实际的需求是Subscriber<String>
Subscriber<String[]> sub = new Subscriber<String[]>() {
@Override
public void onCompleted() {
Log.d("log","Completed");
}
@Override
public void onError(Throwable e) {
Log.d("log","Error");
}
@Override
public void onNext(String[] strings) {
for (String s: strings
) {
Log.d("log","next is "+s);
}
}
};
ob.subscribe(sub);
}
Log信息如下图：
可见循环是写在
Subscriber里面的，意味着这个处理是由生产线最后的消费者（订阅者）来一个个拆开String[]箱子，拿到里面的String做处理，如果我是消费者，这种产品不符合我的要求，我还得自己去适应它，我去，买这种产品自己找虐！所以，生产线就应该满足消费者的需要。
String[] strs = new String[]{"i", "am", "a", "boy", "!"};
Observable<String[]> ob = Observable.just(strs);
//这是消费者的实际需求
Subscriber<String> sub = new Subscriber<String>() {
@Override
public void onCompleted() {
Log.d("log", "Completed");
}
@Override
public void onError(Throwable e) {
Log.d("log", "Error");
}
@Override
public void onNext(String s) {
Log.d("log", "next is " + s);
}
};
//flatmap操作符将输入流转换成所需要的输出流
ob.flatMap(new Func1<String[], Observable<String>>() {
@Override
public Observable<String> call(String[] strings) {
return Observable.from(strings);
}
}).subscribe(sub);
结果是一样的
甚至可以搞搞坏，换个性别
ob.flatMap(new Func1<String[], Observable<String>>() {
@Override
public Observable<String> call(String[] strings) {
return Observable.from(strings);
}
}).flatMap(new Func1<String, Observable<String>>() {
@Override
public Observable<String> call(String s) {
if(s.equals("boy")){
s= "girl";
}
return Observable.just(s);
}
}).subscribe(sub);
不止这些，我还将两个API的调用组合到一个链式调用中了。我们可以将任意多个API调用链接起来。大家应该都应该知道同步所有的API调用，然后将所有API调用的回调结果组合成需要展示的数据是一件多么蛋疼的事情。这里我们成功的避免了callback hell（多层嵌套的回调，导致代码难以阅读维护）。现在所有的逻辑都包装成了这种简单的响应式调用。
大神特地指出了这种链式调用的优点，不得不说，链式调用是真的符合人的思维模式。
