如何在成功和错误的情况下延迟RxJava订阅？

import io.reactivex.Observable;
import io.reactivex.schedulers.Schedulers;

public class DelaySubscriptionExample {
    public static void main(String[] args) {
        Observable<String> observable = Observable.create(emitter -> {
            // 模拟网络请求
            // 在这里执行一些操作，例如发送网络请求获取数据
            // ...

            // 模拟成功情况
            boolean success = true;
            if (success) {
                emitter.onNext("Data received");
                emitter.onComplete();
            } else {
                emitter.onError(new Exception("Error occurred"));
            }
        });

        // 延迟订阅
        Observable<String> delayedObservable = observable
                .delay(2000, TimeUnit.MILLISECONDS, Schedulers.computation());

        // 订阅延迟后的Observable
        delayedObservable.subscribe(
                data -> System.out.println("onNext: " + data),
                error -> System.out.println("onError: " + error.getMessage()),
                () -> System.out.println("onComplete")
        );
    }
}