Android RxJava创建操作符Timer的方法
本文实例为大家分享了AndroidRxJava创建操作符Timer的具体代码，供大家参考，具体内容如下
之前有写过Android实现倒计时之使用CountDownTimer，除了CountDownTimer，开发中我们也会用到handler，例如
mHandler.sendEmptyMessageDelayed(1,10*1000);
privateHandlermHandler=newHandler(){
@Override
publicvoidhandleMessage(Messagemsg){
super.handleMessage(msg);
Log.e("流程","10秒时间已到");
}
};
现在结合RxJava来的Observable.timer操作符，既可以延迟执行一段逻辑，也可以间隔执行一段逻辑
首先添加类库
//RxAndroid compile'io.reactivex:rxandroid:1.2.1' //RxJava compile'io.reactivex:rxjava:1.2.4'
（1）Timer延迟10秒执行：
privatevoidtimer(){
Observable.timer(10000,TimeUnit.MILLISECONDS)
.observeOn(AndroidSchedulers.mainThread())
.subscribe(newAction1(){
@Override
publicvoidcall(LongaLong){
Log.e("流程","10秒倒计时已结束");
}
});
}
（2）Timer间隔1秒执行：
privateSubscriptionsubscribe;
privatevoidtimer(){
subscribe=Observable.timer(1000,1000,TimeUnit.MILLISECONDS).subscribe(newSubscriber(){
@Override
publicvoidonCompleted(){
}
@Override
publicvoidonError(Throwablee){
}
@Override
publicvoidonNext(LongaLong){
Log.e(TAG,"------>along："+aLong+"time:"+SystemClock.elapsedRealtime());
}
});
}
记得要取消订阅
privatevoidstop(){
if(subscribe!=null&&!subscribe.isUnsubscribed()){
subscribe.unsubscribe();
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。