相关文章推荐
有胆有识的高山  ·  药师帮正式登陆港交所-新华网·  1 年前    · 
乖乖的钱包  ·  前说!(Studio五組、AXsiZ制作的电 ...·  1 年前    · 
追风的铁链  ·  亚洲东部是哪-抖音·  1 年前    · 
追风的打火机  ·  锦纶英文_锦纶英语怎么说·  1 年前    · 
知识渊博的冰棍  ·  苏州工业园区获得GB/T ...·  1 年前    · 
小百科  ›  Android RxJava创建操作符Timer的方法开发者社区
handler android开发
还单身的红金鱼
1 年前
作者头像
砸漏
0 篇文章

Android RxJava创建操作符Timer的方法

前往专栏
腾讯云
开发者社区
文档 意见反馈 控制台
首页
学习
活动
专区
工具
TVP
文章/答案/技术大牛
发布
首页
学习
活动
专区
工具
TVP
返回腾讯云官网
社区首页 > 专栏 > 恩蓝脚本 > Android RxJava创建操作符Timer的方法

Android RxJava创建操作符Timer的方法

作者头像
砸漏
发布 于 2020-10-29 22:33:59
1.1K 0
发布 于 2020-10-29 22:33:59
举报

本文实例为大家分享了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操作符,既可以延迟执行一段逻辑,也可以间隔执行一段逻辑

首先添加类库

// 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<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());
 
推荐文章
有胆有识的高山  ·  药师帮正式登陆港交所-新华网
1 年前
乖乖的钱包  ·  前说!(Studio五組、AXsiZ制作的电视动画)_搜狗百科
1 年前
追风的铁链  ·  亚洲东部是哪-抖音
1 年前
追风的打火机  ·  锦纶英文_锦纶英语怎么说
1 年前
知识渊博的冰棍  ·  苏州工业园区获得GB/T 45001认证的企业(单位)名录
1 年前
Link管理   ·   Sov5搜索   ·   小百科
小百科 - 百科知识指南