RxJava使用初级

         说一下感受：自从用了RxJava，我都忘记AsyncTask和Handler怎么用了。

据几个大神说，RxJava牛在它的变换上，但是对于一个要开始接触RxJava的程序猿来讲，完全是不着边际的东西。最初让我最关心的，是它在线程上使用的方便性。

        最简单能使用到的，也是最快入手的，就是使用RxJava来管理线程的事。当然了，RxJava会明显的提升代码量（行数），同时也能显著的简化逻辑结构。一入手时增加的代码量会让人很不爽，但是用几次感受到了逻辑清晰后，就会发现那些多出来的代码量完全值得。

 

        首先列几个词，接下来要常用的：Observable可观察量，subscriber订阅者，subscribeOn()订阅于，observeOn() 观察于，subscribe()订阅。

        举个例子生动一点：假如我要从自助贩货机买杜蕾斯饮料，贩货机里的货物就是Observable可观察量，当然饮料就是包含的对象；我就是subscriber订阅者了决定什么样的我需要，什么样的不要；贩货机视为Observer观察者。

 

       这个时候，将货物（Observable可观察量）中货物进行排查，并通过我（subscriber订阅者）的决定（包含在可观察量中），用subscribe()订阅函数把意图告诉贩货机（Observer观察者），贩货机会做出相应处理。

 

        大概函数如下：

Observable.create(new Observable.OnSubscribe<饮料>() {
@Override
public void call(Subscriber<? super 饮料> subscriber) {
//取到饮料
if(不要)//做判断{
subscriber.onError(new Exception(""));//抛出不要的异常
}
subscriber.onNext(ids);//传递给观察者

}
})
.subscribeOn(Schedulers.io())//指定前面过程在哪里处理
.observeOn(AndroidSchedulers.mainThread())//指定后面的过程在哪里处理
.subscribe(new Observer<DataModel>() {
@Override
public void onCompleted() {
//进行结束的操作
}

@Override
public void onError(Throwable e) {
ToastUtil.show(getActivity(),"我不需要了");
}

@Override
public void onNext(DataModel dataModel) {
//买到手
}
});

 

        以上代码结构可以看作是RxJava最基础的完整结构，完整是因为这个例子中包括了subscribeOn()和.observeOn()这两个指定线程的函数。单纯的代码只执行在调用线程，可以忽略这两个函数。

        前后的泛型是需要统一的,不然会报错，将来涉及转换的时候，对应的泛型类型需要对应统一，这是后话。