Senden Sie angesammelte Anfragen an Webservice - RxJava2

Question

Ich habe Button in meiner App hinzufügen, um Benutzer Element zu einer Liste hinzufügen, wenn Benutzer auf die Schaltfläche Hinzufügen klicken ich nicht die Anfrage, um sofort zum Webservice zu gehen, möchte ich die Anfrage angesammelt werden und gesendet alle 1 Sekunden mit der Gesamtzahl der Klicks. Anstatt die Anfrage jedes Mal zu senden, wenn der Benutzer auf die Schaltfläche Hinzufügen klickt.

Ich sah, dass es so etwas für RxSearchView implementiert ist. Ich überprüfte den Code es ist zu kompliziert

Ich benötige Hilfe mit, wo sollte ich mit solch einem Problem beginnen? oder irgendeine fertige Lösung dafür?

Answer 1

Sie suchen debounce Betreiber:

Gibt einen beobachtbaren, die die Quelle ObservableSource spiegelt, mit der Ausnahme, dass es Elemente von der Quelle ObservableSource emittierten Tropfen, die durch neuere Elemente gefolgt werden, bevor ein Timeout-Wert abläuft. Der Timer wird bei jeder Emission zurückgesetzt. wickeln

einfach Ihre Click-Ereignisse in Observable:

Observable<Object> getButtonObservable(final Button button) { 
    return Observable.create(new ObservableOnSubscribe<Object>() { 
     @Override 
     public void subscribe(final ObservableEmitter<Object> e) throws Exception { 
      button.setOnClickListener(new View.OnClickListener() { 
       @Override 
       public void onClick(View v) { 
        e.onNext(new Object()); //instead of Object you can use any data, e.g. derived from View tag 
       } 
      }); 
      e.setCancellable(new Cancellable() { 
       @Override 
       public void cancel() throws Exception { 
        button.setOnClickListener(null); 
       } 
      }); 
     } 
    }); 
} 

Und dann Anwendung, wenn Betreiber nicht in onDestroy (onDestroyView) austragen zu vergessen:

Button addButton; 
Disposable addButtonDisposable; 

@Override 
protected void onCreate(Bundle savedInstanceState) { 
    super.onCreate(savedInstanceState); 
    ... 
    getButtonObservable(addButton) 
      .doOnSubscribe(new Consumer<Disposable>() { 
       @Override 
       public void accept(Disposable disposable) throws Exception { 
        addButtonDisposable = disposable; 
       } 
      }) 
      .debounce(1, TimeUnit.SECONDS) 
      ... //make request using flatMap or doOnNext, and subscribe 
} 

@Override 
protected void onDestroy() { 
    super.onDestroy(); 
    addButtonDisposable.dispose(); 
}