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", "停止"); } }以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持VEVB武林網。
|
新聞熱點
疑難解答