android - Retrofit 2 + RxJava 取消/取消订阅

Question

我正在执行一个发送文件和消息的网络请求。我想选择取消当前请求。我发现了两个类似的问题，并且都建议 observable.subscribe(Observer) 返回具有方法 unsubscribe() 的 Subscription 对象。

Here is the first one

And the second one

在我的例子中，我使用 observable.subscribe(Observer) 这是无效的。这是我的代码:

Observable<MessengerRaw> observable = mModel.sendMessage(message, companion, description, multiParts);
        observable.subscribe(new Observer<MessengerRaw>() {
            @Override
            public void onSubscribe(Disposable d) {

            }

            @Override
            public void onNext(MessengerRaw value) {
                if (getView() != null) {
                    ((MessengerActivity) getView()).resetMessegeView();
                    ((MessengerActivity) getView()).updateMessageList();
                }
            }

            @Override
            public void onError(Throwable e) {
                getData().remove(0);
                if (getView() != null) {
                    ((MessengerActivity) getView()).updateMessageList();
                }
            }

            @Override
            public void onComplete() {
                hideProgress();
            }
        });

那么我如何取消订阅/取消我的请求？谢谢。

Answer 1

在RxJava2中，你可以在oserver的onSubscribe回调方法中获取Disposable对象，用于处理订阅。