1、rxjava是一种基于观察者模式的响应式编程框架，其中的主要角色有：observable 是rxjava描述的事件流，在链式调用中非常清晰，事件从创建到加工处理再到被订阅者接收到，就是一个接一个的observable形成的一个事件流。
2、每一步方法的调用，都会返回一个新的observable给下一步，这个是rxjava源码的基础。同样是链式调用，但它与我们常见的builder模式不太一样，每个操作符，每次线程切换，每步都会新建一个observable而非直接加工上一步的observable返回给下一步。
3、observableonsubscribe 是这个事件流的源头，下面我们称之为事件源，一般由我们自己创建并传入。我们创建时，需要重写其subscribe()方法，为了和observable中的subscribe()方法区别，我们将在下面贴出的代码中将其改名为call()。
4、我们在调用链中有时会用到各种操作符进行一些变换，事实上每个操作符都会重写这么一个call()方法，相对于我们创建事件源时在这里写入的源业务代码，这些操作符在这里要做的事是由rxjava钦定的，一般是连接事件流的上下游。在这里我们将准备好被订阅的数据，并调用subscribe()参数中observableemitter的onnext()，oncompleted()或onerror()通知订阅者数据准备情况。
5、observer 是整个事件流的订阅者，也就是说，它将会订阅前面事件创建，加工以后的最终结果。它也是由我们创建的，我们将要重写它的onnext()，oncompleted()，onerror()和onsubscribe()，在接下来的分析中我们将简化一些，只关注onnext()。我们创建出了observer以后，将会使用经过上面所有步骤的最后一步生成的observable，调用它的subscribe()，与事件源产生联系。