rxjava 示例代码

以下是一个简单的 RxJava 示例代码，使用 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.just("Hello", "RxJava");

        Observer<String> observer = new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                // 不需要做任何事情
            }

            @Override
            public void onNext(String s) {
                String modifiedString = s.toUpperCase();
                System.out.println(modifiedString);
            }

            @Override
            public void onError(Throwable e) {
                e.printStackTrace();
            }

            @Override
            public void onComplete() {
                System.out.println("完成处理字符串序列");
            }
        };

        observable.subscribe(observer);
    }
}

运行代码后，控制台将输出以下内容：

HELLO
RXJAVA
完成处理字符串序列