Android RxJava创建操作符Interval

// RxAndroidcompile 'io.reactivex:rxandroid:1.2.1'// RxJavacompile 'io.reactivex:rxjava:1.2.4'

 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", "执行一次");      }     });  } }

private void stop() {  if (subscribe != null && !subscribe.isUnsubscribed()) {   subscribe.unsubscribe();   Log.e("1234", "停止");  } }