如何处理列表中的所有项目，然后使用RxJava完成

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

public class ListProcessingExample {
    public static void main(String[] args) {
        // 创建一个包含项目的列表
        String[] items = {"item1", "item2", "item3"};

        // 使用RxJava的Observable创建可观察对象
        Observable<String> observable = Observable.fromArray(items);

        // 使用RxJava的操作符对可观察对象进行转换和处理
        observable
                .map(item -> item.toUpperCase()) // 将项目转换为大写
                .filter(item -> item.startsWith("ITEM")) // 筛选以"ITEM"开头的项目
                .subscribe(new Observer<String>() {
                    @Override
                    public void onSubscribe(Disposable d) {
                        // 订阅时的操作
                    }

                    @Override
                    public void onNext(String item) {
                        // 对每个项目的处理逻辑
                        System.out.println(item);
                    }

                    @Override
                    public void onError(Throwable e) {
                        // 发生错误时的操作
                    }

                    @Override
                    public void onComplete() {
                        // 完成时的操作
                    }
                });
    }
}