AndroidRxJava创建操作符Timer的方法

本文实例为大家分享了Android RxJava创建操作符Timer的具体代码,供大家参考,具体内容如下

创新互联提供网站设计、网站制作、网页设计,成都品牌网站建设广告投放等致力于企业网站建设与公司网站制作,10多年的网站开发和建站经验,助力企业信息化建设,成功案例突破上千,是您实现网站建设的好选择.

之前有写过Android实现倒计时之使用CountDownTimer,除了CountDownTimer,开发中我们也会用到handler,例如

mHandler.sendEmptyMessageDelayed(1, 10*1000);
  private Handler mHandler = new Handler() {
    @Override
    public void handleMessage(Message msg) {
      super.handleMessage(msg);
      Log.e("流程", "10秒时间已到");
    }
  };

现在结合RxJava来的Observable.timer操作符,既可以延迟执行一段逻辑,也可以间隔执行一段逻辑

首先添加类库

// RxAndroid
compile 'io.reactivex:rxandroid:1.2.1'
// RxJava
compile 'io.reactivex:rxjava:1.2.4'

(1)Timer 延迟10秒执行:

private void timer() {
    Observable.timer(10000, TimeUnit.MILLISECONDS)
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Action1() {
          @Override
          public void call(Long aLong) {
            Log.e("流程", "10秒倒计时已结束");
          }
        });
  }

(2)Timer 间隔1秒执行:

 private Subscription subscribe;
  private void timer() {
    subscribe= Observable.timer(1000,1000,TimeUnit.MILLISECONDS).subscribe(new Subscriber() {
      @Override
      public void onCompleted() {
      }

      @Override
      public void onError(Throwable e) {

      }

      @Override
      public void onNext(Long aLong) {
        Log.e(TAG, "------>along:"+aLong+" time:"+ SystemClock.elapsedRealtime());
      }
    });
  }

记得要取消订阅

 private void stop() {
    if (subscribe != null && !subscribe.isUnsubscribed()) {
      subscribe.unsubscribe();
    }
  }

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


网站名称:AndroidRxJava创建操作符Timer的方法
转载源于:http://lszwz.com/article/jdgocc.html

其他资讯

售后响应及时

7×24小时客服热线

数据备份

更安全、更高效、更稳定

价格公道精准

项目经理精准报价不弄虚作假

合作无风险

重合同讲信誉,无效全额退款