最近Android6.0的权限问题，要把之前的APP进行改造，用到了RxPermission框架！之前了解过RXJAVA，但是由于之前项目一直没有使用这个框架，所以也就一直搁置了。正好Rxpermission框架里用到了RXJAVA的内容，索性就学习了一下。
在正文开始之前的最后，放上 GitHub 链接和引入依赖的 gradle 代码： Github：
https://github.com/ReactiveX/RxJava
https://github.com/ReactiveX/RxAndroid
引入依赖：
compile 'io.reactivex:rxjava:1.0.14'
compile 'io.reactivex:rxandroid:1.0.1'
RxJava 好在哪（很多blog文都有这句话，随大流，copy过来）
换句话说，『同样是做异步，为什么人们用它，而不用现成的 AsyncTask / Handler / XXX / … ？』
一个词：简洁。
异步操作很关键的一点是程序的简洁性，因为在调度过程比较复杂的情况下，异步代码经常会既难写也难被读懂。 Android 创造的 AsyncTask 和Handler ，其实都是为了让异步代码更加简洁。RxJava 的优势也是简洁，但它的简洁的与众不同之处在于，随着程序逻辑变得越来越复杂，它依然能够保持简洁。
Rxjava基本原理就是观察者(ObServer)通过(Subscribe)订阅被观察者(Observable),看一个简单的例子
1.首先创建订阅者Observer
Observer<String> observer = new Observer<String>() {
@Override
public void onCompleted() {
//任务完成时出发
} @Override
public void onError(Throwable e) {
//队列发生异常时出发
} @Override
public void onNext(String s) {
Toast.makeText(MainActivity.this, s, Toast.LENGTH_SHORT).show();
}
};
2.创建被观察者Observable
Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("hello");
}
});
3.通过Subscibe完成双方之间的订阅关系进行关联
observable.subscribe(observer);
Create() 方法是 RxJava 最基本的创造事件序列的方法。基于这个方法， RxJava 还提供了一些方法用来快捷创建事件队列，例如：
just(T...): 将传入的参数依次发送出来。
Observable observable = Observable.just("hello","h1","h2","....");
from(T[])/from(Iterable<? extends T>): 将传入的数组或Iterable拆分成具体对象后，依次发送出来
String[] strs = {"小明", "小红", "小芳"};
Observable observable = Observable.from(strs);
或者传入列表
ArrayList<String> strLists = new ArrayList<>();
strLists.add("小明");
strLists.add("小明1");
strLists.add("小明2");
Observable observable = Observable.from(strLists);
这些都可以和上面的onCreate()达到相同的效果
随着学习的深入再继续下一步。今天先消化这些，哈哈哈
