rx.Observable

`rx.Observable`是RxJava 1.x版本中的类，用于创建和操作数据流。RxJava 1.x是旧版本的RxJava，而现在已经推出了RxJava 2.x和3.x版本。

在RxJava 2.x和3.x中，`rx.Observable`被替换为`io.reactivex.rxjava3.core.Observable`。如果你正在使用RxJava 2.x或3.x版本，请使用新的包名和类名。以下是一个使用RxJava 3.x的示例：

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

public class Main {
    public static void main(String[] args) {
        Observable<String> observable = Observable.just("Hello, RxJava!");

        Observer<String> observer = 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() {
                // 完成时调用
            }
        };

        observable.subscribe(observer);
    }
}

上面的代码创建了一个简单的Observable，通过`just`方法发射了一个字符串。然后，创建了一个Observer对象来处理数据流，最后通过`subscribe`方法将Observable和Observer连接起来。

这只是一个简单的示例，你可以使用各种操作符和线程调度器来处理更复杂的数据流。希望这个示例能帮助你理解RxJava的基本用法。如果你有更多问题，请随时提问！