RxJava操作符实践：1_创建操作之8_repeat

一、描述

创建一个发射特定数据重复多次的Observable。

Repeat重复地发射数据。某些实现允许你重复的发射某个数据序列，还有一些允许你限制重复的次数。

RxJava将这个操作符实现为repeat方法。它不是创建一个Observable，而是重复发射原始Observable的数据序列，这个序列或者是无限的，或者通过repeat(n)指定重复次数。

repeat操作符默认在trampoline调度器上执行。有一个变体可以通过可选参数指定Scheduler。

二、示意图

三、示例代码

Observable.range(2, 3)
    .repeat(2)
    .subscribe(new Subscriber<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(Integer integer) {
            System.out.println("onNext: " + integer);
        }
    });

四、运行结果

onNext: 2
onNext: 3
onNext: 4
onNext: 2
onNext: 3
onNext: 4
onCompleted.

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

五、更多

跟repeat相关的操作符还有：

• repeatWhen
• doWhile
• whileDo

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

六、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS：欢迎关注 SherlockShi 个人博客