compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
compile 'io.reactivex.rxjava2:rxjava:2.0.1'

compile 'com.jakewharton.rxbinding2:rxbinding:2.0.0'
compile 'com.jakewharton.rxbinding2:rxbinding-support-v4:2.0.0'
compile 'com.jakewharton.rxbinding2:rxbinding-appcompat-v7:2.0.0'

Observable<Long> mObservableCountTime = RxView.clicks(mBtnSendMsm)
  //防止重復(fù)點(diǎn)擊
  .throttleFirst(MAX_COUNT_TIME, TimeUnit.SECONDS)
  //將點(diǎn)擊事件轉(zhuǎn)換成倒計(jì)時(shí)事件
  .flatMap(new Function<Object, ObservableSource<Long>>() {
    @Override
    public ObservableSource<Long> apply(Object o) throws Exception {
      //更新發(fā)送按鈕的狀態(tài)并初始化顯現(xiàn)倒計(jì)時(shí)文字
      RxView.enabled(mBtnSendMsm).accept(false);
      RxTextView.text(mBtnSendMsm).accept("剩余 " + MAX_COUNT_TIME + " 秒");

      //在實(shí)際操作中可以在此發(fā)送獲取網(wǎng)絡(luò)的請求

      //返回 N 秒內(nèi)的倒計(jì)時(shí)觀察者對象。
      return Observable.interval(1, TimeUnit.SECONDS, Schedulers.io()).take(MAX_COUNT_TIME);
    }
  })
  //將遞增數(shù)字替換成遞減的倒計(jì)時(shí)數(shù)字
  .map(new Function<Long, Long>() {
    @Override
    public Long apply(Long aLong) throws Exception {
      return MAX_COUNT_TIME - (aLong + 1);
    }
  })
  .observeOn(AndroidSchedulers.mainThread());//切換到 Android 的主線程。

Consumer<Long> mConsumerCountTime = new Consumer<Long>() {
  @Override
  public void accept(Long aLong) throws Exception {
    //顯示剩余時(shí)長。當(dāng)?shù)褂?jì)時(shí)為 0 時(shí)，還原 btn 按鈕.
    if (aLong == 0) {
      RxView.enabled(mBtnSendMsm).accept(true);
      RxTextView.text(mBtnSendMsm).accept("發(fā)送驗(yàn)證碼");
    } else {
      RxTextView.text(mBtnSendMsm).accept("剩余 " + aLong + " 秒");
    }
  }
};

 //訂閱點(diǎn)擊事件
 Disposable mDisposable = mObservableCountTime.subscribe(mConsumerCountTime);

//重置驗(yàn)證碼按鈕。
RxView.clicks(mBtnClean).subscribe(new Consumer<Object>() {
  @Override
  public void accept(Object o) throws Exception {
    if (mDisposable != null && !mDisposable.isDisposed()) {
      //停止倒計(jì)時(shí)
      mDisposable.dispose();
      //重新訂閱
      mDisposable = mObservableCountTime.subscribe(mConsumerCountTime);
      //按鈕可點(diǎn)擊
      RxView.enabled(mBtnSendMsm).accept(true);
      RxTextView.text(mBtnSendMsm).accept("發(fā)送驗(yàn)證碼");
    }
  }
});

@Override
protected void onDestroy() {
  super.onDestroy();
  if (mDisposable != null) {
    mDisposable.dispose();
  }
}