相信看完前两篇文章，相信大家对RxJava的用例已经有个比较清晰的认识了。今天我们来看看RxJava的一个extension-RxAndroid。

RxAndroid的官方Wiki，和github。

1.RxAndroid主线程调度器

说到RxAndroid，大部分已经接触过RxJava的同学都可能看过这个类似的代码

mainThread()

没错，就是这个AndroidSchedulers.mainThread()线程调度器。在经典的安卓后台处理，主线程接收结果场景中经常被使用。

不过说实话，我个人在参与公司的app编写的过程中，RxAndroid部分最常用到的也就是这个调度器而已了。。。

真的就这么没用嘛

RxAndroid当然不止这么点用处，我们接下来探索一下其他RxAndroid的用例。

首先我们打开RxAndroid的Wiki Page，可以看到有一大堆extension呢！

一大堆RxAndroid的extension

今天我们就以其中一个最常用的RxBinding为例。

RxBinding是用来干哈的？我个人的理解是它是一个把android中各种view的listener转换成Rx里面的Observable的一个库。一个最简单的例子：替换掉view的onClicklistener:

Rxbinding的方式来监听click事件

哈哈！成功啦！我们迈向了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的大小？

why?

因为一旦subscribe，我们的Observable会每隔一段时间(就是你定义的时间),发射一个集合，这个集合可能是空的，或者只含有一个元素(比如说在500ms里面你压根没点击，或者只点击了一次)。

3.优雅的响应改变

第三部分的例子来源于这个家伙写的一个blog文章,假设你有一个textview，和一个edittext，每次edittext改变的时候你都想把edittext的内容转换顺序，并且显示到textview上面。使用rxbinding将edittext的响应事件更优雅的来处理把！

优雅的处理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的一些源代码。