.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

rxjava2 doOnNext doOnSubscribe 线程的关系

原文：https://www.cnblogs.com/caosq/p/12144533.html