RxView.debounce wartet auf den Zeitraum der Entprellung, um den Befehl auszuführen, wie führe ich den Befehl sofort aus?

Question

Ich habe den folgenden Code in meinem Android-App, mehrere Klicks auf eine Schaltfläche zu verhindern versuchen: von

RxView.clicks(bSubmit) 
      .debounce(2500, TimeUnit.MILLISECONDS) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(c -> displayToast()); 

aber statt der Ausführung des Codes und dann verhindert mehrere Klicks in der gleichen Zeitspanne wird beaufschlagt, Was dieser Code tut ist, dass er den Befehl ausführt, nachdem die Debounce-Zeitspanne abgelaufen ist.

Wie kann ich erreichen, was ich will?

Answer 1

Nach Reactivex.io documentation, debounce emittieren das letzte Ereignis während eines Zeitfensters.

Was Sie wollen, ist das erste Ereignis während eines Zeitfensters zu emittieren, das, was nicht throttleFirst (siehe documentation).

RxView.clicks(bSubmit) 
     .throttleFirst(2500, TimeUnit.MILLISECONDS) 
     .observeOn(AndroidSchedulers.mainThread()) 
     .subscribe(c -> displayToast());