Nachrufanrufe, die bei Entprellen mit einem Betreff mehrfach ausgeführt werden

Question

Ich folgte diesem Link How to debounce a retrofit reactive request in java?, um eine nachträgliche reaktive Anfrage zu debuntieren. Unten ist mein Stück Code

//i declare the subject globally 
PublishSubject<Call<List<Response>>> subject = PublishSubject.create(); 

//this is how i call retrofit 
private void updateMarkers(LatLng center) 
{ 
    subject.onNext(new APIHelper(). 
       GetNearByLocations("auth_key", center.latitude, center.longitude, urgency)); 

    subject.debounce(1, TimeUnit.SECONDS) 
       .observeOn(AndroidSchedulers.mainThread()) 
       .subscribeOn(Schedulers.io()) 
       .subscribe(call -> { 
        call.clone().enqueue(new Callback<List<Response>>() 
        { 
         @Override 
         public void onResponse(Call<List<Response>> call, Response<List<Response>> response) 
         { 
          Timber.d("BRAVO!!!"); 
         } 

         @Override 
         public void onFailure(Call<List<Response>> call, Throwable t) 
         { 
          Timber.d("someone's gonna get hurt real bad!!!"); 
         } 
        }); 

       }); 
    } 

Dies ist, was geschieht. Jedes Mal, wenn die updateMarkers() -Methode aufgerufen wird, erstellt Retrofit einen neuen call.clone() und die Anzahl der Aufrufe meines Backends wird jedes Mal um 1 erhöht. Ich habe auch versucht, APIHelper() global zu deklarieren und das gleiche Objekt zu verwenden, um meinen Back-End-Aufruf zu machen. Aber das Ergebnis ist das gleiche. Bitte helfen Sie mir mit einigen Tipps, um dieses Problem zu lösen.

Answer 1

Im konkreten Fall fügen Sie jedes Mal einen Teilnehmer hinzu, wenn updateMarkers aufgerufen wird.

Um zu erreichen, was Sie wollen, müssen Sie die Erstellung Ihrer beobachtbare in einem anderen Verfahren bewegen müssen, zum Beispiel onResume oder onCreate:

//i declare the subject globally 
PublishSubject<Call<List<Response>>> subject = PublishSubject.create(); 

private void updateMarkers(LatLng center) 
{ 
    subject.onNext(new APIHelper(). 
      GetNearByLocations("auth_key", center.latitude, center.longitude, urgency)); 

} 

@Override 
public void onResume(Context ctx) { 


     subject.debounce(1, TimeUnit.SECONDS) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribeOn(Schedulers.io()) 
      .subscribe(call -> { 
       call.clone().enqueue(new Callback<List<Response>>() 
       { 
        @Override 
        public void onResponse(Call<List<Response>> call, Response<List<Response>> response) 
        { 
         Timber.d("BRAVO!!!"); 
        } 

        @Override 
        public void onFailure(Call<List<Response>> call, Throwable t) 
        { 
         Timber.d("someone's gonna get hurt real bad!!!"); 
        } 
       }); 

      }); 
} 

Bitte beachten Sie, dass Sie Retrofit 2 mit RxJava verwenden können :

Ihre API:

public interface MyApi { 
      Observable<String> getNearByLocation(Double latitude, Double longitude); 
} 

Ihre Aktivität: