How to cancel request with retofit2 and RxAndroid

Question

I am using Retrofit 2.0 and Rx-android to load my APIs. I follow the section RxJava Integration with CallAdapter at this site and it work fine. But, I don't know how to cancel a loading request with the observable object. Please help to give me an idea.

Answer 1

The only way to cancel RxJava Observable execution - unsubscribe from it. RxJavaCallAdapter will delegate cancel to okhttp client.

So, you simple do smth like this:

Subscription subscription = getObservable().subscribe();

//When you want to stop execution
subscription.unsubsribe();

You can check out the code here. Concretely these lines if code

final Call<T> call = originalCall.clone();

// Attempt to cancel the call if it is still in-flight on unsubscription.
subscriber.add(Subscriptions.create(new Action0() {
  @Override public void call() {
    call.cancel();
  }
}));