Android RxJava创建 *** 作符Timer的方法

概述本文实例为大家分享了AndroidRxJava创建 *** 作符Timer的具体代码，供大家参考，具体内容如下

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

之前有写过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 *** 作符，既可以延迟执行一段逻辑，也可以间隔执行一段逻辑

首先添加类库

// RxAndroIDcompile 'io.reactivex:rxandroID:1.2.1'// RxJavacompile 'io.reactivex:rxjava:1.2.4'

（1）Timer 延迟10秒执行：

private voID timer() {    Observable.timer(10000,TimeUnit.MILliSECONDS)        .observeOn(AndroIDSchedulers.mainThread())        .subscribe(new Action1<Long>() {          @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<Long>() {      @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();    }  }

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

总结

以上是内存溢出为你收集整理的Android RxJava创建 *** 作符Timer的方法全部内容，希望文章能够帮你解决Android RxJava创建 *** 作符Timer的方法所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。