使用Rx为每个事件生成具有延迟的第二个后续事件

import io.reactivex.Observable;
import java.util.concurrent.TimeUnit;

public class RxExample {
    public static void main(String[] args) {
        Observable<Integer> source = Observable.just(1, 2, 3, 4, 5);

        source.flatMap(event -> Observable.timer(1000, TimeUnit.MILLISECONDS)
                .map(timerEvent -> "Delayed event: " + event))
                .subscribe(System.out::println);

        // 等待一段时间，确保所有事件都被处理完毕
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}