RxJava实现遍历List集合定时发射每条数据

场景：遍历一个List集合，每次循环结束都等待一定时间再继续下一次循环。

普通做法

for (String s : strings) {
    Thread.sleep(1000);
}

上面这种做法简单粗暴，就是不够优雅，在子线程进行时，循环没结束且刚好在sleep中时，我们尝试interrupt此子线程的时候会抛java.lang.InterruptedException异常

RxJava做法：使用ZIP操作符

        List<String> list = new ArrayList<>();
        list.add("1");
        list.add("2");
        list.add("3");
        list.add("4");
        list.add("5");

        //fromIterable接收一个Iterable，每次发射一个元素（与for循环效果相同）
        Observable<String> listObservable = Observable.fromIterable(list);
        //interval定时器，间隔1秒发射一次
        Observable<Long> timerObservable = Observable.interval(1000, TimeUnit.MILLISECONDS);
        //使用zip操作符合并两个Observable
        Observable.zip(listObservable, timerObservable, new BiFunction<String, Long, String>() {
            @Override
            public String apply(String s, Long aLong) throws Exception {
                return s;
            }
        }).doOnNext(new Consumer<String>() {
            @Override
            public void accept(String s) throws Exception {
                //此处接收
            }
        }).subscribe();

zip操作符：

zip操作符

也就是说，通过zip操作符将listObservable和timerObservable合并之后，实现的效果就是：
发射list第一个元素 → 延时1秒 → 发射list第二个元素 → 延时1秒......

使用RxJava这种方式实现，要比for循环里使用Thread.sleep()更加优雅一些，还能避免java.lang.InterruptedException异常

PS：delay操作符无法实现，因为delay用于事件流中，只能延迟发射事件流中的某一次事件