轻松实现Rxjava定时器功能

网友投稿 390 2023-01-27


轻松实现Rxjava定时器功能

使用Rxjava实现定时器功能可以通过两种方式来实现,具体实现如下:

一、使用 timer 操作符

WxiXO

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

}

});

}

/**

* 关闭定时器

WxiXO*/

public void closeTimer(){

if (mDisposable != null) {

mDisposable.dispose();

}

}


版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:接口自动化测试有什么用(接口自动化测试有什么用处)
下一篇:双斜杠连接共享文件夹失败(双斜杠连接共享文件夹失败原因)
相关文章

 发表评论

暂时没有评论,来抢沙发吧~