如何以响应式方式更改Single<T>对象的状态？

import io.reactivex.Single;
import io.reactivex.SingleObserver;
import io.reactivex.disposables.Disposable;

public class SingleExample {
    public static void main(String[] args) {
        // 创建Single对象
        Single<String> single = Single.create(emitter -> {
            // 模拟异步操作
            Thread.sleep(1000);
            // 发射数据
            emitter.onSuccess("Data");
        });

        // 订阅观察者
        single.subscribe(new SingleObserver<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                // 可选的，可以在这里处理订阅事件
            }

            @Override
            public void onSuccess(String data) {
                // 处理成功的情况
                System.out.println("Success: " + data);
            }

            @Override
            public void onError(Throwable e) {
                // 处理错误的情况
                System.out.println("Error: " + e.getMessage());
            }
        });
    }
}