DoubleClick----RxJava

gistfile1.txt

public void doubleClickDetect(View view){
        Observable<Void> observable = RxView.clicks(view).share();
        observable.buffer(observable.debounce(200, TimeUnit.MILLISECONDS))
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Action1<List<Void>>() {
                    @Override
                    public void call(List<Void> voids) {
                        if(voids.size() >= 2){
                        	//double click detected
                        }
                    }
                }, new Action1<Throwable>() {
                    @Override
                    public void call(Throwable throwable) {
                        Timber.e(throwable, "error");
                    }
                });
    }

nice, very useful, thanks! I would add a filter and a map to get the first click (almost similar to the 2nd) and put everything inside a ObservableTransformer to use with compose:

    @NotNull
    public static  <T> ObservableTransformer<T, T> doubleClick() {
        return upstream -> {
            Observable<T> shared = upstream.share();
            return shared
                    .buffer(upstream.debounce(200, TimeUnit.MILLISECONDS))
                    .filter(list -> list.size()>1)
                    .map(list -> list.get(0));

        };
    }

I think observeOn is not necessary.

without RxView

    private void doubleClickDetect(View view) {
        PublishSubject<Integer> publishSubject = PublishSubject.create();
        publishSubject
                .buffer(publishSubject.debounce(200, TimeUnit.MILLISECONDS))
                .filter(list -> list.size() > 1)
                .subscribe(list -> {
                    //double click detected
                });
        view.setOnClickListener(v -> {
            publishSubject.onNext(0);
        });
    }