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

想了很久怎么样可以让文章的标题不那么悲观，但是各种文案都在我脑海里面不断的被否定，要么是不那么抓眼球，要么是立意不匹配。最后想了想，这个标题是真的符合我最近的感悟。 加上已经四个月没有更新，就写一篇我自己的感想。不过在开始正文之前 ...

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