您的位置:首页 > 移动开发 > Android开发

Android RxJava 创建操作符Interval

2017-06-10 17:32 477 查看
Interval操作符:用于创建Observable,跟TimerTask类似,用于周期性发送信息,是一个可以指定线程的TimerTask

首先添加类库

// RxAndroid
compile 'io.reactivex:rxandroid:1.2.1'
// RxJava
compile 'io.reactivex:rxjava:1.2.4'


(1) 间隔时间3秒发送一次

private Subscription subscribe;
private void start() {
if (subscribe == null || subscribe.isUnsubscribed()) {
subscribe = Observable.interval(3000, 3000, TimeUnit.MILLISECONDS)//延时3000 ,每间隔3000,时间单位
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<Long>() {
@Override
public void call(Long aLong) {
Log.e("1234", "执行一次");
}
});
}
}


(2)取消订阅

private void stop() {
if (subscribe != null && !subscribe.isUnsubscribed()) {
subscribe.unsubscribe();
Log.e("1234", "停止");
}
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: