一、描述

创建一个按固定时间间隔发射整数序列的Observable。

Interval操作符返回一个Observable，它按固定的时间间隔发射一个无限递增的整数序列。

还有一个版本的interval返回一个Observable，它在指定延迟之后先发射一个零值，然后再按照指定的时间间隔发射递增的数字。这个版本的interval在RxJava 1.0.0中叫做timer，但是那个方法已经不建议使用了，因为一个名叫interval的操作符有同样的功能。

interval默认在computation调度器上执行。你也可以传递一个可选的Scheduler参数来指定调度器。

二、示意图

interval

三、示例代码

protected void runSampleCode() {
    Observable observable = Observable.interval(1000, TimeUnit.MILLISECONDS);

    subscriber = new Subscriber<Long>() {
        @Override
        public void onCompleted() {
            System.out.println("onCompleted.");
        }

        @Override
        public void onError(Throwable e) {
            System.out.println("onError: " + e.getMessage());
        }

        @Override
        public void onNext(Long aLong) {
            System.out.println("onNext: " + aLong);
        }
    };

    observable.subscribe(subscriber);
}

@Override
protected void onDestroy() {
    super.onDestroy();

    if (subscriber!= null
            && !subscriber.isUnsubscribed()) {
        subscriber.unsubscribe();
    }
}

四、运行结果

onNext: 0
onNext: 1
onNext: 2
onNext: 3
onNext: 4
onNext: 5
(...)

注意点：

这个对象是运行在computation Scheduler，所以如果需要在view中显示结果，要在主线程中订阅。
由于这个操作会无限进行下去，所以需要手动取消掉这个subscription。

项目代码已上传到Github：https://github.com/SherlockShi/RxJavaBestPractise

五、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS：欢迎关注 SherlockShi 个人博客