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 线程的关系的主要内容,如果未能解决你的问题,请参考以下文章

RxJava操作符doOnNext

doOnNext() 不会被称为 Spring Webflux

RXJAVA-doOnNext

RXJAVA-doOnNext

RXJAVA-doOnNext

RXJAVA-doOnNext