Jak anulować zadanie z modernizacją i rxjava

Question

Mam api odpoczynku.

@Get("/serveraction") 
public Observable<String> myRequest(@Query("Data") String data); 

wiem, że okhttp jest anulowanie funkcjonalność (na żądanie obiektu, przez tag), ale nie wiem jak go używać z modernizacją i rxjava. Jaki jest najlepszy sposób na zrealizowanie mechanizmu anulowania dla zadań sieciowych za pomocą modernizacji i rxjava?

Answer 1

Można użyć standardowego mechanizmu anulowania RxJava Subscription.

Observable<String> o = retrofit.getObservable(..); 
Subscription s = o.subscribe(...); 

// later when not needed 
s.unsubscribe(); 

Złącze RxJava Retrofit przekieruje to połączenie do anulowania OKHttp. Zobacz tutaj: https://github.com/square/retrofit/blob/master/retrofit-adapters/rxjava/src/main/java/retrofit2/RxJavaCallAdapterFactory.java#L102

Answer 2

Wybrana odpowiedź dotyczy Rx Java 1 i nie jest poprawna dla RxJava2. W przypadku tego ostatniego można użyć jednorazowego użytku. Postępuj w ten sposób:

1. Definiowanie CompositeDisposable compositeDisposable=new CompositeDisposable() jako pole w Activity lub Fragment w klasie.

2. Zdefiniuj API używając Modernizacja 2 jak coś takiego:

   public Observable<YourPojo> callApiWithRetrofit() { 
       return getService(YourApiService.class).callApi(); 
   } 
   

3. Define Disposable i dodać go do instancji compositeDisposable:

   Disposable disposable = callApiWithRetrofit().subscribeOn(Schedulers.io()).observeOn(
        AndroidSchedulers.mainThread()).subscribeWith(
        new DisposableObserver<List<YourPojo>>() { 
         @Override 
         protected void onStart() { 
          super.onStart(); 
         } 
   
         @Override 
         public void onNext(@NonNull List<AlertAssetDTO> listResponse) { 
   
         } 
   
         @Override 
         public void onError(@NonNull Throwable e) { 
   
         } 
   
         @Override 
         public void onComplete() { 
   
         } 
        }); 
   mCompositeDisposable.add(alertAssetsDisposable); 
   

4. Gdziekolwiek chcesz połączenie ma być anulowane (np. onDestroy() metoda twojego Activity lub onDestroyView() twojego Fragment) wywołanie mCompositeDisposable.clear();

W ten sposób można dodać wiele materiałów jednorazowego użytku do urządzenia CompostieDisposable.