Interval *** 作符:用于创建Observable,跟TimerTask类似,用于周期性发送信息,是一个可以指定线程的TimerTask
首先添加类库
// RxAndroIDcompile 'io.reactivex:rxandroID:1.2.1'// RxJavacompile '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","停止"); } }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持编程小技巧。
总结以上是内存溢出为你收集整理的Android RxJava创建 *** 作符Interval全部内容,希望文章能够帮你解决Android RxJava创建 *** 作符Interval所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)