android使用Rxjava实现倒计时功能

 /**
 * 点击获取验证码，10S倒计时，利用Rxjava进行线程切换
 * @param view
 */
 public void getSureCode(View view) {
 Observable.create(new ObservableOnSubscribe() {
  @Override
  public void subscribe(ObservableEmitter emitter) throws Exception {
  int i = 10;
  while (i >= 0) {
   try {
   Thread.sleep(1000);
   emitter.onNext(i);
   } catch (InterruptedException e) {
   e.printStackTrace();
   }
   i--;
  }
  emitter.onComplete();
  }
 }).subscribeOn(Schedulers.io())// 此方法为上面发出事件设置线程为IO线程
  .observeOn(AndroidSchedulers.mainThread())// 为消耗事件设置线程为UI线程
  .subscribe(new Consumer() {
   @Override
   public void accept(Integer integer) throws Exception {
   bindingView.countDownTv.setClickable(integer > 0 &＃63; false : true);
   bindingView.countDownTv.setBackground(integer > 0 &＃63; getResources().getDrawable(R.drawable.rectangle_gray_bg) : getResources().getDrawable(R.drawable.rectangle_red_bg));
   if(integer > 0) {
    String cOntent= integer + "秒后可重新发送";
    SpannableString span = new SpannableString(content);
    int index = content.indexOf("后");
    span.setSpan(new ForegroundColorSpan(getResources().getColor(R.color.colorTheme)), 0, index, Spanned.SPAN_EXCLUSIVE_EXCLUSIVE); //设置前景色为红色
    bindingView.countDownTv.setText(span);
   } else {
    bindingView.countDownTv.setText(getString(R.string.get_check_code));
   }
   }
  });
 }

<&＃63;xml version="1.0" encoding="utf-8"&＃63;>

 
 
 
 
 
 

<&＃63;xml version="1.0" encoding="utf-8"&＃63;>

 
 
 
 
 
 

#FFDDDDDD
#f64a33