Android 用RxBinding与RxJava2实现短信验证码倒计时功能

场景：注册账号页面时，我们点击按钮发送验证码，在等待验证码时，界面会有倒计时提示，这此期间按钮不可点击。当倒计时结束时，按钮恢复。

实现与功能都不难，这次用 rxbinding，rxjava2 的方法去实现。并实现了手动、自动停止倒计时，防止多次点击。

功能动态图

要使用 rxbinding、rxjava2 先添加 gradle 配置:

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'

首先通过 rxview.clicks() 绑定并转换成一个倒计时的 observable 观察者对象。

observable<long> mobservablecounttime = rxview.clicks(mbtnsendmsm)
  //防止重复点击
  .throttlefirst(max_count_time, timeunit.seconds)
  //将点击事件转换成倒计时事件
  .flatmap(new function<object, observablesource<long>>() {
    @override
    public observablesource<long> apply(object o) throws exception {
      //更新发送按钮的状态并初始化显现倒计时文字
      rxview.enabled(mbtnsendmsm).accept(false);
      rxtextview.text(mbtnsendmsm).accept("剩余 " + max_count_time + " 秒");

      //在实际操作中可以在此发送获取网络的请求

      //返回 n 秒内的倒计时观察者对象。
      return observable.interval(1, timeunit.seconds, schedulers.io()).take(max_count_time);
    }
  })
  //将递增数字替换成递减的倒计时数字
  .map(new function<long, long>() {
    @override
    public long apply(long along) throws exception {
      return max_count_time - (along + 1);
    }
  })
  .observeon(androidschedulers.mainthread());//切换到 android 的主线程。

设置作为倒计时提示的 consumer 被观察者对象。

consumer<long> mconsumercounttime = new consumer<long>() {
  @override
  public void accept(long along) throws exception {
    //显示剩余时长。当倒计时为 0 时，还原 btn 按钮.
    if (along == 0) {
      rxview.enabled(mbtnsendmsm).accept(true);
      rxtextview.text(mbtnsendmsm).accept("发送验证码");
    } else {
      rxtextview.text(mbtnsendmsm).accept("剩余 " + along + " 秒");
    }
  }
};

订阅点击事件:

 //订阅点击事件
 disposable mdisposable = mobservablecounttime.subscribe(mconsumercounttime);

停止倒计时，但依然可以再次点击。

//重置验证码按钮。
rxview.clicks(mbtnclean).subscribe(new consumer<object>() {
  @override
  public void accept(object o) throws exception {
    if (mdisposable != null && !mdisposable.isdisposed()) {
      //停止倒计时
      mdisposable.dispose();
      //重新订阅
      mdisposable = mobservablecounttime.subscribe(mconsumercounttime);
      //按钮可点击
      rxview.enabled(mbtnsendmsm).accept(true);
      rxtextview.text(mbtnsendmsm).accept("发送验证码");
    }
  }
});

退出当前页面时，销毁清空数据。

@override
protected void ondestroy() {
  super.ondestroy();
  if (mdisposable != null) {
    mdisposable.dispose();
  }
}

源码：倒计时的各种花式实现

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。