RxJava 学习05 RxJava2 多线程

RxJava 学习05 RxJava2 多线程

RxJava 学习05 RxJava2 多线程

RxJava 学习05 RxJava2 多线程

RxJava 学习05 RxJava2 多线程

创建worker,然后按照周期执行任务

RxJava 学习05 RxJava2 多线程

再来看schedulePeriodicallyDirect

RxJava 学习05 RxJava2 多线程

RxJava 学习05 RxJava2 多线程

提交到executor执行,然后返回future

RxJava 学习05 RxJava2 多线程

执行异常,就会调用RxJavaPlugins.onError处理

6.2 SubscribeOn操作

RxJava 学习05 RxJava2 多线程

RxJava 学习05 RxJava2 多线程

RxJava 学习05 RxJava2 多线程

6.3 ObserveOn操作

RxJava 学习05 RxJava2 多线程