Size: a a a
A
EG
healthCheckApi.healthCheck()
.doOnComplete {
Single.error(throwable)
}
.doOnError {
enableSystemOnError()
}
.onErrorResumeNext {
Single.error(MyException())
}
EG
A
EG
l
completable.toObservable.swithIfEmpty.onErrorResumeWithEG
val singleSource: SingleSource<out Nothing> = Single.error(throwable)?
val singleSource1: SingleSource<Throwable> = Single.error(throwable)
PE
PE
PE
PE
I
val sharedObs = getObservable()Нужно ли, когда я подпишусь на
.subscibeOn(Schedulers.io())
.distinctUntilChanged()
.share()
sharedObs вызывать .subscribeOn(Schedulers.io()) ?sharedObs
.subscribeOn(Schedulers.io()) // или это избыточно?
.map {}
.other {}
.observeOn(AndroidShedulers.mainThread())
.another {}l
NS
NS
l
I
NS
l
l
