如何转换为Rx java Observable

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

public class RxJavaExample {
    public static void main(String[] args) {
        // 创建Observable对象
        Observable<String> observable = Observable.just("Hello", "World");

        // 订阅观察者
        observable.subscribe(new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                // 可选实现
            }

            @Override
            public void onNext(String s) {
                // 处理接收到的数据
                System.out.println(s);
            }

            @Override
            public void onError(Throwable e) {
                // 处理错误
            }

            @Override
            public void onComplete() {
                // 处理完成通知
            }
        });
    }
}