轻松实现Rxjava定时器功能

2019-10-21 21:49:12

字体：大中小

来源：转载

供稿：网友

使用RxJava实现定时器功能可以通过两种方式来实现，具体实现如下：

一、使用 timer 操作符

private Disposable mDisposable; /**  * 启动定时器  */ public void startTime() {  Observable.timer(10, TimeUnit.SECONDS)    .subscribeOn(Schedulers.io())    .observeOn(AndroidSchedulers.mainThread())    .subscribe(new Observer<Long>() {     @Override     public void onSubscribe(Disposable d) {      mDisposable = d;     }     @Override     public void onNext(Long value) {      //Log.d("Timer",""+value);     }     @Override     public void onError(Throwable e) {     }     @Override     public void onComplete() {      // TODO:2017/12/1      closeTimer();     }    }); } /**  * 关闭定时器  */ public void closeTimer(){  if (mDisposable != null) {   mDisposable.dispose();  } }

二、使用使用 interval 和 take 操作符

在1.x 中 timer 可以执行间隔逻辑，在2.x中此功能已过时，交给了 interval 操作符,当然只使用 interval 还不能实现定时器功能，必须再结合take 操作符。具体代码如下：

private Disposable mDisposable; /**  * 启动定时器  */ public void startTime() {  int count_time = 10; //总时间  Observable.interval(0, 1, TimeUnit.SECONDS)    .take(count_time+1)//设置总共发送的次数    .map(new Function<Long, Long>() {     @Override     public Long apply(Long aLong) throws Exception {      //aLong从0开始      return count_time-aLong;     }    })    .subscribeOn(Schedulers.io())    .observeOn(AndroidSchedulers.mainThread())    .subscribe(new Observer<Long>() {     @Override     public void onSubscribe(Disposable d) {      mDisposable = d;     }     @Override     public void onNext(Long value) {      //Log.d("Timer",""+value);     }     @Override     public void onError(Throwable e) {     }     @Override     public void onComplete() {      // TODO:2017/12/1      closeTimer();     }    }); } /**  * 关闭定时器  */ public void closeTimer(){  if (mDisposable != null) {   mDisposable.dispose();  } }

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持VEVB武林网。

注：相关教程知识阅读请移步到Android开发频道。

上一篇：Rxjava实现发送验证码倒计时功能

下一篇：基于Rxjava实现轮询定时器