一、描述

将一个发射数据的Observable转换为发射那些数据发射时间间隔的Observable。

TimeInterval操作符拦截原始Observable发射的数据项，替换为发射表示相邻发射物时间间隔的对象。

RxJava中的实现为timeInterval，这个操作符将原始Observable转换为另一个Obserervable，后者发射一个标志替换前者的数据项，这个标志表示前者的两个连续发射物之间流逝的时间长度。新的Observable的第一个发射物表示的是在观察者订阅原始Observable到原始Observable发射它的第一项数据之间流逝的时间长度。不存在与原始Observable发射最后一项数据和发射onCompleted通知之间时长对应的发射物。

timeInterval默认在immediate调度器上执行，你可以通过传参数修改。

二、示意图

timeInterval

三、示例代码

Observable.create(new Observable.OnSubscribe<Integer>() {
    @Override
    public void call(Subscriber<? super Integer> subscriber) {
        for (int i = 1; i < 4; i++) {
            try {
                Thread.sleep(100 * i);
            } catch (InterruptedException e) {
                subscriber.onError(e);
            }
            subscriber.onNext(i);
        }
        subscriber.onCompleted();
    }
})
    .timeInterval()
    .subscribeOn(Schedulers.newThread())
    .subscribe(new Subscriber<TimeInterval<Integer>>() {
        @Override
        public void onCompleted() {
            System.out.println("onCompleted.");
        }

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

        @Override
        public void onNext(TimeInterval<Integer> timeInterval) {
            System.out.println("onNext: interval=" + timeInterval.getIntervalInMilliseconds() + ", Value=" +timeInterval.getValue());
        }
    });

四、运行结果

onNext: interval=100, Value=1
onNext: interval=100, Value=2
onNext: interval=100, Value=3
onCompleted.

五、更多

delay操作符还有以下变体：

timeInterval()
timeInterval(Scheduler)

详情可查阅下面的参考资料。

六、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS：欢迎关注SherlockShi博客