Preventing rapid clicks with RXJava

Question

I am writing an android app and using rxjava to handle user input events. Basically what I want to do is, emit when a button is clicked, and then drop subsequent emissions for some period of time afterwards (like a second or two), essentially to prevent having to process multiple clicks of the button.

If you don't necessarily want to drop for some period of time, but rather drop as long as the processing is going on, you can [take advantage of the backpressure](https://stackoverflow.com/q/52966919/1916449). — arekolek, Oct 24 '18 at 11:51

score 6 · Accepted Answer · answered Mar 06 '14 at 10:17

6

I think throttleFirst is what you want: https://github.com/Netflix/RxJava/wiki/Filtering-Observables#wiki-throttlefirst

answered Mar 06 '14 at 10:17

zsxwing

20,270
4
37
59

1

Here is an example especially for this purpose: http://stackoverflow.com/a/35705364/1732338 – Nikita Barishok Feb 29 '16 at 17:12

score 3 · Answer 2 · answered Sep 28 '19 at 12:52

3

For preventing fast clicks i use this code

RxView.clicks(your_view)
            .throttleFirst(300, TimeUnit.MILLISECONDS)
            .subscribe {
                //on click
            }

answered Sep 28 '19 at 12:52

Radesh

13,084
4
51
64

Aks4125 · Answer 3 · 2022-02-09T16:55:33.490

2

Continuing zsxwing's Answer:

If you're not using RxBinding library but only RxJava then,

io.reactivex.Observable.just(view_obj)
                .throttleFirst(1, TimeUnit.SECONDS)// prevent rapid click for 1 seconds
                .blockingSubscribe(o -> {                     
                    startActivity(...);
                });

edited Feb 09 '22 at 16:55

answered May 01 '19 at 10:30

Aks4125

4,522
4
32
48

The blockingSubscribe never gets called. – Sai Mar 24 '20 at 06:34

score -1 · Answer 4 · answered Jul 05 '16 at 15:27

This can be done with share debounce and buffer operator

Observable<Object> tapEventEmitter = _rxBus.toObserverable().share();
Observable<Object> debouncedEventEmitter = tapEventEmitter.debounce(1, TimeUnit.SECONDS);
Observable<List<Object>> debouncedBufferEmitter = tapEventEmitter.buffer(debouncedEventEmitter);

debouncedBufferEmitter.buffer(debouncedEventEmitter)
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(new Action1<List<Object>>() {
      @Override
      public void call(List<Objecenter code heret> taps) {
        _showTapCount(taps.size());
      }
    });

Preventing rapid clicks with RXJava

4 Answers4

Linked