如何在rxJava中不断尝试直到成功

Observable.create((ObservableOnSubscribe<String>) emitter -> {
    // 模拟一个可能会失败的操作
    if (Math.random() < 0.8) {
        emitter.onError(new Exception("操作失败"));
    } else {
        emitter.onNext("操作成功");
        emitter.onComplete();
    }
})
.retryWhen(errors -> errors
    .flatMap(error -> {
        // 判断错误类型，决定是否要重试
        if (error instanceof Exception) {
            // 如果是某种特定的错误类型，可以进行重试
            return Observable.just(error);
        } else {
            // 如果是其他类型的错误，不进行重试
            return Observable.error(error);
        }
    })
    .delay(1, TimeUnit.SECONDS) // 延迟1秒后进行重试
)
.subscribe(
    result -> System.out.println("操作成功：" + result),
    error -> System.out.println("操作失败：" + error.getMessage())
);