Android RxJava创建操作符Timer的方法
时间：2021-10-31 08:46:10|栏目：Android代码|点击： 次
本文实例为大家分享了Android RxJava创建操作符Timer的具体代码，供大家参考，具体内容如下
之前有写过Android实现倒计时之使用CountDownTimer，除了CountDownTimer，开发中我们也会用到handler，例如
mHandler.sendEmptyMessageDelayed(1, 10*1000);
private Handler mHandler = new Handler() {
@Override
public void handleMessage(Message msg) {
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秒执行：
private void timer() {
Observable.timer(10000, TimeUnit.MILLISECONDS)
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<Long>() {
@Override
public void call(Long aLong) {
Log.e("流程", "10秒倒计时已结束");
}
});
}
（2）Timer 间隔1秒执行：
private Subscription subscribe;
private void timer() {
subscribe= Observable.timer(1000,1000,TimeUnit.MILLISECONDS).subscribe(new Subscriber<Long>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(Long aLong) {
Log.e(TAG, "------>along："+aLong+" time:"+ SystemClock.elapsedRealtime());
}
});
}
记得要取消订阅
private void stop() {
if (subscribe != null && !subscribe.isUnsubscribed()) {
subscribe.unsubscribe();
}
}
