Throtle first

Throtle first

package com.don.myapplication;

import androidx.appcompat.app.AppCompatActivity;

import android.os.Bundle;
import android.util.Log;
import android.widget.Button;

import com.jakewharton.rxbinding3.view.RxView;

import java.util.concurrent.TimeUnit;

import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.CompositeDisposable;
import io.reactivex.schedulers.Schedulers;


public class TestingActivity extends AppCompatActivity {

    Button btnSubmit, btnTest;
    int count = 0;

    public CompositeDisposable compositeDisposable;


    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_testing);

        btnSubmit = findViewById(R.id.btn1);
        btnTest = findViewById(R.id.btn2);

        compositeDisposable = new CompositeDisposable();


    }

    @Override
    protected void onStart() {
        super.onStart();
        compositeDisposable.add(RxView.clicks(btnSubmit)
                .observeOn(Schedulers.io())
                .throttleFirst(1000, TimeUnit.MILLISECONDS)
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(v -> Log.e("TAG", "Berapa kali di click " + count++)));

    }

    @Override
    protected void onStop() {
        compositeDisposable.clear();
        super.onStop();
    }


}