相信看完前两篇文章,相信大家对RxJava的用例已经有个比较清晰的认识了。今天我们来看看RxJava的一个extension-RxAndroid。
1.RxAndroid主线程调度器
说到RxAndroid,大部分已经接触过RxJava的同学都可能看过这个类似的代码
没错,就是这个AndroidSchedulers.mainThread()线程调度器。在经典的安卓后台处理,主线程接收结果场景中经常被使用。
不过说实话,我个人在参与公司的app编写的过程中,RxAndroid部分最常用到的也就是这个调度器而已了。。。
RxAndroid当然不止这么点用处,我们接下来探索一下其他RxAndroid的用例。
首先我们打开RxAndroid的Wiki Page,可以看到有一大堆extension呢!
今天我们就以其中一个最常用的RxBinding为例。
RxBinding是用来干哈的?我个人的理解是它是一个把android中各种view的listener转换成Rx里面的Observable的一个库。一个最简单的例子:替换掉view的onClicklistener:
哈哈!成功啦!我们迈向了RxAndroid的第一步。。。。。。。我露出了尴尬的笑容
乍一看,这有啥意义吗?从原来的setOnclickListener()到现在这个bingding,并没有看到有什么优势啊。
年轻人别上火,咱们来仔细分析一下。既然我们成功的把一个view的click事件转换成了Observable,那么我们就可以玩很多花活了,所有在Observable上可以应用的操作符我们现在都可以应用到android的view上拉!
2.实现双击响应!
比如说,假如我们想实现一个按钮双击的响应事件,在android里面应该怎么实现呢?先贴出代码,我们再仔细分析分析。
可以看到我们在这个例子里面,把原始的textview的observable通过buffer()操作符改装了一下。让我们看看buffer是干嘛的。
周期性的把一个原始的Observable要发射的元素集中在多个集合里面,然后把这些集合一个个发射出去(而不是原始的元素)。
这和我们双击事件有什么联系呢?让我们来想想,双击鼠标,双击button,本质是什么?本质就是在一个比较短的时间段内,点击了目标两次,不能是一次,也不能是三次。这个比较短的时间是多少,一秒?两秒?不重要。因为这是由开发者自己决定的。那么使用buffer操作符的话,我们可以不断的监听我们的click事件的同时,把他们按照两个两个的组合起来,那么每次我们就只处理这个两个点击事件的集合,而不是单个点击事件。
看看buffer的使用,四个参数:
参数1:时间段的长短
参数2:时间段的单位
参数3:我们选择发射集合的大小,这里因为我们需要的是双击事件,所以这个参数3我们会选择2.
参数4:线程调度器,这里我们在安卓的主线程监听事件的发生。
至于在subscribe里面,为什么我们还需要判断一下list的大小?
因为一旦subscribe,我们的Observable会每隔一段时间(就是你定义的时间),发射一个集合,这个集合可能是空的,或者只含有一个元素(比如说在500ms里面你压根没点击,或者只点击了一次)。
3.优雅的响应改变
第三部分的例子来源于这个家伙写的一个blog文章,假设你有一个textview,和一个edittext,每次edittext改变的时候你都想把edittext的内容转换顺序,并且显示到textview上面。使用rxbinding将edittext的响应事件更优雅的来处理把!
4.上述例子的一些缺点。
稍微陈述一下上述例子的缺点吧。
首先例子1的双击事件,每次在subscribe之后,RxJava都会开启一个timer,定时的去获取事件。这样具体对手机power的消耗是否会增加太多,我不太确定。但是肯定是比不用timer要多的
例子2中,RxTextView的textChanges()方法之响应了EditText的onTextChanged()方法。beforeTextChanged 和 afterTextChanged是没有响应的。大家有兴趣可以看看它的实现,就是把textwatcher的方法重写,每次onTextChanged的时候就发射一个事件。
5.最后关于流的思考。
其实写了这些例子并不是为了要大家就按照我写的去做,具体项目的需求不一样,写法肯定也不一样。我写这些的目的是为了让大家可以明白,RxAndroid的这些extension,例如rxbinding的存在意义是什么。
他们的意义是,把平常我们在安卓开发接触过程中的一些组件,以RxJava概念里面的流(Stream)呈现出来。就像大部分文章里面提到的,在Rx的世界里面,everything is stream。或者更详细的说,everything is event stream。这也呼应了Rx的event-driven的本质。
这里的stream,流,和我们在java api里面的stream理解稍微不太一样。Rx里面的流,可以理解为一个事件的流,这个流可以是从一个List里面提取的,拥有有限个元素的流,或者是一个网络请求的流,有限个元素,但是你不知道它从一个元素的发射到下一个元素的发射需要多久(网络请求时间),又或者是像点击事件这种,拥有无限个元素,发射间隔完全取决于用户。
这就是为什么RxJava在他们的wiki page里面,每一个operator都配上了一个,一条直线,一个箭头,直线上有若干元素的图了。
时间朝着箭头的方向走,事件也有序的一个个发射。
变成流之后,我们就可以用各种操作符把原始的流,改变成我们需要的流了,每一次我们使用一个操作符比如filter, map等,我们其实已经把原始的流改变成一个新的流了。
这是我个人关于Rx里面的流的一点思考,希望对大家有帮助。
最后
最近工作有点忙,关于RxJava的文章会在两周之后更新。我会着重讲解一下RxJava的一些源代码。