rx-java – 如何在onComplete之后显式取消订阅observable

发布时间：2020-12-15 04:41:30 所属栏目：Java 来源：网络整理

导读：在下面的代码中,在完成onComplete之后,unSubscribe如何以及在何处明确地明确地取消订阅Observable？ getObservable() .observeOn(AndroidSchedulers.mainThread()) .subscribeOn(Schedulers.io()) .subscribe(new SubscriberBoolean() { @Override public vo

在下面的代码中,在完成onComplete之后,unSubscribe如何以及在何处明确地明确地取消订阅Observable？

getObservable()
    .observeOn(AndroidSchedulers.mainThread())
    .subscribeOn(Schedulers.io())
    .subscribe(new Subscriber<Boolean>() {
        @Override
        public void onCompleted() {
            doSomething();
        }

        @Override
        public void onError(Throwable e) {
            thereIsError();
        }

        @Override
        public void onNext(Boolean status) {
            updateView();
        }
    });

解决方法

您可以保存subscribe方法返回的Disposable,并在onCompleted回调中使用它

Disposable d = 
getObservable()
    .observeOn(AndroidSchedulers.mainThread())
    .subscribeOn(Schedulers.io())
    .subscribe(new Subscriber<Boolean>() {
        @Override
        public void onCompleted() {
            doSomething();
            d.dispose();
        }

        @Override
        public void onError(Throwable e) {
            thereIsError();
        }

        @Override
        public void onNext(Boolean status) {
            updateView();
        }
    });

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!