rxjava2 doOnNext doOnSubscribe 線程的關系

.compose(
    xxxx
).doOnNext {
    //doOnNext 0 ------------> RxCachedThreadScheduler-8
    KLog.i("doOnNext 0 ------------> ${Thread.currentThread().name}")
}.subscribeOn(Schedulers.io()).doOnNext {
    //doOnNext 1 ------------> RxCachedThreadScheduler-8
    KLog.i("doOnNext 1 ------------> ${Thread.currentThread().name}")
}.observeOn(AndroidSchedulers.mainThread()).doOnNext {
    //doOnNext 2 ------------> main
    KLog.i("doOnNext 2 ------------> ${Thread.currentThread().name}")
}.doOnSubscribe(viewModel).doOnSubscribe {
    //doOnSubscribe ------------> main
    KLog.i("doOnSubscribe ------------> ${Thread.currentThread().name}")
    viewModel.showDialog()
}.doOnError {
    KLog.e(it.printStackTrace())
    viewModel.dismissDialog()
}.doOnComplete {
    viewModel.dismissDialog()
}

RxJava強大的線程控制

https://www.jianshu.com/p/404ca4e3e85d