rxjava interval 恢复

在 RxJava 中，`interval` 操作符用于创建一个按固定时间间隔发射整数序列的 Observable。如果需要在某个时刻取消或暂停 `interval` 发射的序列，可以使用 `dispose` 方法来取消订阅。

下面是一个使用 `interval` 操作符的示例代码：

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

public class IntervalExample {
    public static void main(String[] args) throws InterruptedException {
        Observable<Long> observable = Observable.interval(1, TimeUnit.SECONDS);
        Disposable disposable = observable.subscribe(System.out::println);

        // 模拟等待 5 秒后取消订阅
        Thread.sleep(5000);
        disposable.dispose();
        
        // 模拟等待 5 秒后重新订阅
        Thread.sleep(5000);
        observable.subscribe(System.out::println);
        
        // 模拟等待 10 秒后退出应用
        Thread.sleep(10000);
    }
}

在上述示例中，我们创建了一个每秒发射一个整数的 Observable，并通过 `subscribe` 方法订阅它。然后，我们等待 5 秒后调用 `dispose` 方法取消订阅。接着，我们再等待 5 秒后重新订阅，可以看到计数从头开始。最后，我们等待 10 秒后退出应用。

请注意，`interval` 操作符会在调用 `dispose` 方法后停止发射序列，所以在重新订阅之前需要创建一个新的 Observable 对象。