基于RxJava框架实现获取验证码的辅助类

package txcap.com.bigtime.utils;import android.widget.Button;import android.widget.EditText;import com.jakewharton.rxbinding.view.RxView;import com.jakewharton.rxbinding.widget.RxTextView;import java.util.concurrent.TimeUnit;import rx.Observable;import rx.Subscriber;import rx.Subscription;import rx.android.schedulers.AndroidSchedulers;import rx.functions.Action0;import rx.functions.Action1;import txcap.com.bigtime.Constant;import txcap.com.bigtime.R;import txcap.com.library.core.app.BaseApplication;import txcap.com.library.core.rx.RxManager;import txcap.com.library.utils.file.ResUtil;/** * @author gaojigong * @version V1.0 * @Description: 处理验证码的工具 * @date 17/3/22 */public abstract class CheckCodeUtil {  private RxManager mRxManager;  private Button btnGetCheckCode;  private EditText edtAccount;  //验证码获取中，按钮始终是倒计时状态，不受输入框事件的影响  protected boolean countDowning = false;  //用于取消倒计时  private Subscription intervalSub;  public CheckCodeUtil(RxManager mRxManager, Button btnGetCheckCode, EditText edtAccount) {    this.mRxManager = mRxManager;    this.btnGetCheckCode = btnGetCheckCode;    this.edtAccount = edtAccount;    init();  }  private void init() {    RxView.enabled(btnGetCheckCode).call(false);    Observable<CharSequence> observableAccount = RxTextView.textChanges(edtAccount);    //账号输入不合理不能点击获取验证码    mRxManager.add(observableAccount        .subscribeOn(AndroidSchedulers.mainThread())        .subscribe(new Action1<CharSequence>() {          @Override          public void call(CharSequence charSequence) {            if(!countDowning){//这样能减少重复执行              if (etCheck(charSequence.toString())) {                RxView.enabled(btnGetCheckCode).call(true);              } else {                RxView.enabled(btnGetCheckCode).call(false);              }            }          }        }));    //点击获取验证码    mRxManager.add(        RxView.clicks(btnGetCheckCode)            .throttleFirst(Constant.CLICK_THROTTLE, TimeUnit.SECONDS)            .subscribe(new Action1<Void>() {              @Override              public void call(Void aVoid) {                getCheckCode();              }            })    );  }  /**   * 获取验证码   */  private void getCheckCode() {    intervalSub = Observable.interval(0,1,TimeUnit.SECONDS, AndroidSchedulers.mainThread())        .take(Constant.CHECK_CODE_SECOND)        .doOnSubscribe(new Action0() {          @Override          public void call() {            getCodeNumber();            //按钮变为不可点击            RxView.enabled(btnGetCheckCode).call(false);            countDowning = true;          }        })        .subscribe(new Subscriber<Long>() {          @Override          public void onCompleted() {            countDowning = false;            RxTextView.text(btnGetCheckCode).call(ResUtil.getResString(BaseApplication.getAppContext(),R.string.get_check_code));            if(etCheck(edtAccount.getText().toString())){              RxView.enabled(btnGetCheckCode).call(true);            }          }          @Override          public void onError(Throwable e) {            countDowning = false;            RxTextView.text(btnGetCheckCode).call(ResUtil.getResString(BaseApplication.getAppContext(),R.string.get_check_code));            if(etCheck(edtAccount.getText().toString())){              RxView.enabled(btnGetCheckCode).call(true);            }          }          @Override          public void onNext(Long aLong) {            RxTextView.text(btnGetCheckCode).call((Constant.CHECK_CODE_SECOND - aLong)+"s");          }        });    mRxManager.add(intervalSub);  }  /**   * 获取验证码   */  public abstract void getCodeNumber();  /**   * 验证规则   * @param str   * @return   */  public abstract boolean etCheck(String str);  public void getCodeError(){    if(null != intervalSub){      if(!intervalSub.isUnsubscribed()){        intervalSub.unsubscribe();        RxTextView.text(btnGetCheckCode).call(ResUtil.getResString(BaseApplication.getAppContext(),R.string.get_check_code));        RxView.enabled(btnGetCheckCode).call(true);        countDowning = false;      }    }  }}

@BindView(R.id.edt_account)EditText edtAccount;@BindView(R.id.btn_get_check_code)Button btnGetCheckCode;private CheckCodeUtil checkCodeUtil;checkCodeUtil = new CheckCodeUtil(mRxManager,btnGetCheckCode,edtAccount) {  @Override  public void getCodeNumber() {    mPresenter.getCode(edtAccount.getText().toString());  }  @Override  public boolean etCheck(String str) {    return StrCheckUtil.checkedAccount(str);  }};@Overridepublic void getCodeFailed(String message) {  showToastLong("获取验证码失败:" + message);  checkCodeUtil.getCodeError();}