RxJava是一个基于变形的观察者模式实现的，RxJava中的观察者模式可以通过观察者创建另一个观察者，从而实现链式调用。下面以Observable的create操作符为例分析。 create操作符接收一个ObservableOnSubscribe类型的匿名内部类，在回调方法subscribe中可以发射一个事件。

You signed in with another tab or window. Reloadto refresh your session. You signed out in another tab or window. Reloadto refresh your session. You switched accounts on another tab or window.

阅读本文需要对Rxjava了解，如果还没有了解或者使用过Rxjava的兄die们，可以观看我另外一篇 Android Rxjava：图解不一样的诠释 进行学习。 Rxjava背压：被观察者发送事件的速度大于观察者接收事件的速度时，观察者内会创建一个无限制大少的缓冲池存储未接收的 ...