rxjava2 doOnNext doOnSubscribe 线程的关系
Posted caosiqiao
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了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
以上是关于rxjava2 doOnNext doOnSubscribe 线程的关系的主要内容,如果未能解决你的问题,请参考以下文章