rxJava,rxAndroid实现1秒内只能进行一次有效点击

添加依赖
dependencies {

    compile 'io.reactivex:rxjava:1.1.0'
    compile 'io.reactivex:rxandroid:1.1.0'

}

核心代码package com.example.liuan.gaojishizhan;

import android.graphics.BitmapFactory;
import android.graphics.drawable.BitmapDrawable;
import android.os.Bundle;
import android.os.Environment;
import android.support.v7.app.AppCompatActivity;
import android.view.View;
import android.widget.Button;
import android.widget.LinearLayout;
import android.widget.TextView;

import java.util.Arrays;
import java.util.List;
import java.util.concurrent.TimeUnit;

import rx.Observable;
import rx.Subscriber;
import rx.android.schedulers.AndroidSchedulers;
import rx.functions.Action1;
import rx.schedulers.Schedulers;

public class RxActivity extends AppCompatActivity {
    private Subscriber<? super Object> msubscriber;
    private TextView text;

    private Button btn;

    private LinearLayout main;

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


        main = (LinearLayout) findViewById(R.id.activity_main);
        text = (TextView) findViewById(R.id.text);


        btn = (Button) findViewById(R.id.button);
        String path = Environment.getExternalStorageDirectory().getPath() + "/osc.png";
        System.out.println(path);
        Observable.just(path)
                .map(s -> BitmapFactory.decodeFile(s))
                //让BitmapFactiory.decodeFile(s)允许在子线程
                .subscribeOn(Schedulers.io())
                //.text.setBackGround 允许在子线程
                .observeOn(AndroidSchedulers.mainThread())

                .subscribe(bitmap1 -> text.setBackgroundDrawable(new BitmapDrawable(bitmap1)));

        btn.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                System.out.println("点击了");
                msubscriber.onNext(null);

            }
        });
        Observable.create(new Observable.OnSubscribe<Object>() {


            @Override
            public void call(Subscriber<? super Object> subscriber) {
                msubscriber = subscriber;

            }
        })
                //1s只响应一次点击
                .throttleFirst(1, TimeUnit.SECONDS)
                .subscribe(new Action1<Object>() {
                    @Override
                    public void call(Object o) {
                        System.out.println("处理事件点击");
                    }
                });
    }


    
}
布局文件<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:tools="http://schemas.android.com/tools"
    android:id="@+id/activity_main"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:paddingBottom="@dimen/activity_vertical_margin"
    android:paddingLeft="@dimen/activity_horizontal_margin"
    android:paddingRight="@dimen/activity_horizontal_margin"
    android:paddingTop="@dimen/activity_vertical_margin"
    android:orientation="vertical"
    tools:context="com.example.liuan.gaojishizhan.MainActivity">

    <TextView
        android:id="@+id/text"
        android:layout_width="match_parent"
        android:layout_height="500dp"
 />
    <Button

        android:id="@+id/button"
        android:text="限制按钮"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content" />
</LinearLayout>

效果截图