Android RxJava创建操作符Timer的方法

Android RxJava创建操作符Timer的方法

本文实例为大家分享了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() {

@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() {

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

}

}

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