轻松实现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();
 }
}

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

来源：https://blog.csdn.net/MillerKevin/article/details/78890375