Ndtyjky

I'm using RxJava2 and Retrofit. In my fragment, I make a request to upload a local file:

Disposable disposable = mApi.requestUpload(file)

        .subscribeOn(Schedulers.io())

        .observeOn(AndroidSchedulers.mainThread())

        .subscribe(response -> {

            toast("success");

        }, throwable -> {

            toast("failed");

        });

mCompositeDisposable.add(disposable);

Then, clear all disposables in onDestroyView()

@Override

public void onDestroyView() {

    mCompositeDisposable.clear();

    super.onDestroyView();

}

But I use Charles to view all requests and find that the request is still executing after I finish the fragment. The file is still uploaded successfully after a time.

How can I cancel the call when fragment closed?

use disposable.dipose() for canceling your call.

1. 
   

   Define Disposable

   
   
   

   private io.reactivex.disposables.Disposable mDisposable;

   
   


2. 
   

   assign to your service

   
   
   

   mService.getResults(query)
   
               .observeOn(AndroidSchedulers.from(Looper.getMainLooper(), true))
   
               .subscribeOn(Schedulers.io())
   
               .subscribe(new SingleObserver<Response<Model>>() {
   
                   @Override
   
                   public void onSubscribe(Disposable d) {
   
                       /* required */
   
                       mDisposable = d;
   
                   }
   
   
   
                   @Override
   
                   public void onSuccess(Response<Model> response) {
   
                       dismissProgress();
   
                   }
   
   
   
                   @Override
   
                   public void onError(Throwable e) {
   
   
   
                   }
   
               });
   
   

   
   


3. 
   

   call below line to dismiss/terminate ongoing API call

   
   
   

    if (mDisposable != null)
   
       mDisposable.dispose(); 
   
   

   
   

There you go.

UPDATE

in your case, it should be

@Override

public void onDestroyView() {

if (mCompositeDisposable!= null) // in case if you required-> if (mCompositeDisposable!= null && !mCompositeDisposable.isDisposed())

      mCompositeDisposable.dispose(); 

super.onDestroyView();

}

Add RxJava to CompositeDisposable
Then in onStop()
use disposableRxJava.dispose()