我遇到这样的情况:
outerDisposable = Observable.intervalRange(1,maxCount,initialDelay,interval,TimeUnit.MILLISECONDS,AndroidSchedulers.mainThread())
.subscribeOn(Schedulers.io())
.subscribe(time ->
{
if (time == maxCount) {
liveData.setValue("Event"));
innerDisposable = Completable.complete()
.delay(60000, TimeUnit.MILLISECONDS)
.observeOn(AndroidSchedulers.mainThread())
.doOnComplete(() -> liveData.postValue("Event"))
.subscribe();
} else {
liveData.setValue("Event");
}
});
我的问题是,如果我处理
outerDisposable
那么
innerDisposable
是自动处理还是我每次都要分别处理?