一、前言

    虽然之前也有学习过RxJava，但是因为公司项目没有使用，所以也只是了解了它的一些好处。最近新入职了一家公司，里面大量使用了RxJava，也是时候做一下系统的学习了。关于RxJava的好处现在我先不提，相信你也听说了很多，但是任何一个好的工具能真正帮助到你的前提是，你要长期的去使用，我也相信，再真正的使用过程中，你也能和我一样体会到它真正的精髓。

二、简介

    我们都知道RxJava是一种观察者模式，所以就会有观察者Observer和被观察者Observable。两者中间通过一系列的操作符，将被观察的对象进行转化、筛选等操作，通过subscribe()方法进行绑定，最终发送到观察者上。如下段代码：

       val observable = Observable.create<Int> { emitter ->
            emitter.onNext(1)
            emitter.onNext(2)
            emitter.onNext(3)
            emitter.onComplete()
        }
        val observer = object :Observer<Int>{
            override fun onSubscribe(d: Disposable?) {

            }

            override fun onNext(value: Int) {

            }

            override fun onError(e: Throwable?) {

            }

            override fun onComplete() {

            }
        }
        observable.subscribe(observer)

一般我们会写成链式调用的方式，看起来十分舒畅。

Observable.create<Int> { emitter ->
            emitter.onNext(1)
            emitter.onNext(2)
            emitter.onNext(3)
            emitter.onComplete()
        }.subscribe(object :Observer<Int>{
            override fun onSubscribe(d: Disposable?) {

            }

            override fun onNext(value: Int) {

            }

            override fun onError(e: Throwable?) {

            }

            override fun onComplete() {
                
            }
        })

Observable.create是被观察者的创建过程，我们后面会详细介绍，先看下几个接受的回调方法。
    其中onNext()、onComplete()、onError()就是对应上游emitter中所发送的，emitter顾名思义是一个发射器。几个方法中需要注意的是，你可以发送多个onNext()，但是你只能发送一个onComplete()或者onError()来代表结束，且必须发送。Disposable的翻译是“一次性的”，在这里你可以使用它的 dispose()方法，终止观察。
    如果我们只关注其中的部分回调，subscribe()方法提供了一系列的重载函数如下：

subscribe(onNext : Consumer)
subscribe(onNext : Consumer,onError : Consumer)
subscribe(onNext : Consumer,onError : Consumer,onComplete : Action)
subscribe(onNext : Consumer,onError : Consumer,onComplete : Action,onSubscribe : Consumer)

所以，假如我们只关心onNext的话，可以写成：

Observable.create<Int> { emitter ->
            emitter.onNext(1)
            emitter.onNext(2)
            emitter.onNext(3)
            emitter.onComplete()
        }.subscribe{
            Log.e(TAG,"$it")
        }

三、总结

  RxJava虽然有很多种被观察者，有各种不同的操作符，但是无外乎都是看起来同样的使用方式，只是各自的适用场景不同。现在你已经初步掌握了它，我建议可以在项目中尝试去使用。遇到你需要的场景的时候再去网上进行查找，同时同步的进行一些学习，RxJava能做的比你想的要多。下一章，我们就去来学习创建操作符。