如何使RxJava间隔即使出错也无法停止？

Observable.interval(1, TimeUnit.SECONDS)
    .flatMap(value -> {
        // 执行间隔操作，可以是网络请求、文件读写等
        // 如果发生错误，则抛出异常
        if (value % 3 == 0) {
            throw new Exception("Error occurred");
        } else {
            return Observable.just(value);
        }
    })
    .retryWhen(errors -> errors
        .flatMap(error -> {
            // 在发生错误时，延迟一段时间后重新订阅源Observable
            // 这里使用了指数退避策略，每次重试延迟时间递增
            return Observable.timer(2 ^ errors.takeWhile(e -> !(e instanceof Exception)).count(), TimeUnit.SECONDS);
        })
    )
    .subscribe(
        value -> {
            // 处理每次发射的数据
            System.out.println("Next value: " + value);
        },
        error -> {
            // 处理错误
            System.out.println("Error: " + error.getMessage());
        }
    );