RxJava 学习02 Observable 使用案例01

Observable的使用

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

Observable生命周期的一系列回调

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

 

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

如果所有的订阅者/观察者都取消订阅了,则数据流停止; 如果重新订阅,则重新开始数据流

 

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

下面测试下部分取消订阅再恢复的场景,这样就不会从头开始数据流

RxJava 学习02 Observable 使用案例01

subscriber1和subscriber2 断开后 重新订阅,但是subscriber3不断开

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

Maybe 只能发射0个或者1个数据,多了就不处理

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01

RxJava 学习02 Observable 使用案例01