轻松实现Rxjava定时器功能

 更新时间:2018年06月28日 11:28:15   作者:MillerKevin  
这篇文章主要为大家详细介绍了Rxjava实现定时器功能的两种方式,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

使用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();
  }
 }

二、使用使用 intervaltake 操作符

在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();
  }
 }

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

相关文章

最新评论