这期内容当中小编将会给大家带来有关如何实现一个Rxjava定时器功能，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。
成都网站建设哪家好，找创新互联！专注于网页设计、成都网站建设公司、微信开发、小程序开发、集团成都定制网站等服务项目。核心团队均拥有互联网行业多年经验，服务众多知名企业客户；涵盖的客户类型包括：广告推广等众多领域，积累了大量丰富的经验，同时也获得了客户的一致赞赏！
一、使用 timer 操作符
private Disposable mDisposable;
/**
* 启动定时器
*/
public void startTime() {
Observable.timer(10, TimeUnit.SECONDS)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer() {
@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() {
@Override
public Long apply(Long aLong) throws Exception {
//aLong从0开始
return count_time-aLong;
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer() {
@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();
}
} 上述就是小编为大家分享的如何实现一个Rxjava定时器功能了，如果刚好有类似的疑惑，不妨参照上述分析进行理解。如果想知道更多相关知识，欢迎关注创新互联行业资讯频道。