一、interval语法

    public void rxJavaIntervalExample() {
        LogUtils.error(TAG, "rxJavaIntervalExample--start--:" + Thread.currentThread().getName() + "--:" + TimeUtils.getNowString());
        Disposable disposable = Observable.interval(3, 2, TimeUnit.SECONDS)
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer<Long>() {
                    @Override
                    public void accept(Long aLong) throws Exception {
                        LogUtils.error(TAG, "rxJavaIntervalExample--end--:" + Thread.currentThread().getName() + "--:" + TimeUtils.getNowString() + "---long:" + aLong);
                    }
                });
        compositeDisposable.add(disposable);
    }

日志

08-18 11:04:38.563 7993-7993/com.example.zhang E/MainPresenter: rxJavaIntervalExample--start--:main--:2018-08-18 11:04:38
08-18 11:04:41.744 7993-7993/com.example.zhang E/MainPresenter: rxJavaIntervalExample--end--:main--:2018-08-18 11:04:41---long:0
08-18 11:04:43.743 7993-7993/com.example.zhang E/MainPresenter: rxJavaIntervalExample--end--:main--:2018-08-18 11:04:43---long:1
08-18 11:04:45.742 7993-7993/com.example.zhang E/MainPresenter: rxJavaIntervalExample--end--:main--:2018-08-18 11:04:45---long:2
08-18 11:04:47.740 7993-7993/com.example.zhang E/MainPresenter: rxJavaIntervalExample--end--:main--:2018-08-18 11:04:47---long:3

总结

1、interval 操作符用于间隔时间执行某个操作，其接受三个参数，分别是第一次发送延迟，间隔时间，时间单位