Android RxJava创建操作符Interval

Android RxJava创建操作符Interval

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.MILLISECONDhttp://S)//延时3000 ，每间隔3000，时间单位

.observeOn(AndroidSchedulers.mainThread())

.subscribe(new Action1() {

@Override

public void call(Long aLong) {

Log.e("1234", "执行一次");

}

});

}

}

（2）取消订阅

private void stop() {

if (subscribe != null && !subscribe.isUnsubscribed()) {

subscribe.unsubscribe();

Log.e("1234", "停止");

}

}

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