Dfyjkt

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()