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秒发送一次
privateSubscriptionsubscribe; privatevoidstart(){ if(subscribe==null||subscribe.isUnsubscribed()){ subscribe=Observable.interval(3000,3000,TimeUnit.MILLISECONDS)//延时3000,每间隔3000,时间单位 .observeOn(AndroidSchedulers.mainThread()) .subscribe(newAction1(){ @Override publicvoidcall(LongaLong){ Log.e("1234","执行一次"); } }); } }
(2)取消订阅
privatevoidstop(){ if(subscribe!=null&&!subscribe.isUnsubscribed()){ subscribe.unsubscribe(); Log.e("1234","停止"); } }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。