在RxJava调用后从方法返回字符串

import io.reactivex.Observable;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;

public class RxJavaExample {
    public static void main(String[] args) {
        Observable<String> observable = Observable.create(emitter -> {
            // 执行耗时操作，例如从数据库或网络获取字符串
            String result = "Hello, RxJava!";
            emitter.onNext(result); // 发送结果给订阅者
            emitter.onComplete(); // 完成操作
        });

        Observer<String> observer = new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                // 可选的方法，在订阅时被调用
            }

            @Override
            public void onNext(String s) {
                // 处理返回的字符串
                System.out.println("Received: " + s);
            }

            @Override
            public void onError(Throwable e) {
                // 可选的方法，在发生错误时被调用
            }

            @Override
            public void onComplete() {
                // 可选的方法，在操作完成时被调用
            }
        };

        observable.subscribe(observer); // 执行订阅操作
    }
}