如何使用RXJava 2遍历JSONArray？

implementation 'io.reactivex.rxjava2:rxjava:2.x.x'
implementation 'io.reactivex.rxjava2:rxandroid:2.x.x'

import io.reactivex.Observable;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;
import org.json.JSONArray;
import org.json.JSONException;

public class RxJava2Example {
    public static void main(String[] args) {
        // 示例JSONArray
        JSONArray jsonArray = new JSONArray();
        jsonArray.put("item1");
        jsonArray.put("item2");
        jsonArray.put("item3");

        // 创建Observable
        Observable<String> observable = Observable.create(emitter -> {
            try {
                // 遍历JSONArray
                for (int i = 0; i < jsonArray.length(); i++) {
                    // 发射每个元素
                    emitter.onNext(jsonArray.getString(i));
                }
                // 遍历完成后，发射完成事件
                emitter.onComplete();
            } catch (JSONException e) {
                // 发生异常时，发射错误事件
                emitter.onError(e);
            }
        });

        // 创建Observer
        Observer<String> observer = new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                // 可选实现，当Observable订阅时调用
            }

            @Override
            public void onNext(String s) {
                // 处理每个元素
                System.out.println("Item: " + s);
            }

            @Override
            public void onError(Throwable e) {
                // 处理错误事件
                e.printStackTrace();
            }

            @Override
            public void onComplete() {
                // 处理完成事件
                System.out.println("Traversal completed");
            }
        };

        // 订阅Observable
        observable.subscribe(observer);
    }
}