将Arraylist<Object>方法转换为RxJava可观察值

implementation 'io.reactivex.rxjava3:rxjava:3.x.x'

Observable<ArrayList<Object>> observable = Observable.create(new ObservableOnSubscribe<ArrayList<Object>>() {
    @Override
    public void subscribe(ObservableEmitter<ArrayList<Object>> emitter) throws Exception {
        ArrayList<Object> list = new ArrayList<>();
        // 将ArrayList中的每个元素发送给观察者
        for (Object obj : list) {
            emitter.onNext(obj);
        }
        emitter.onComplete();
    }
});

observable.subscribe(new Observer<ArrayList<Object>>() {
    @Override
    public void onSubscribe(Disposable d) {
        // 可选的，当订阅发生时调用
    }

    @Override
    public void onNext(ArrayList<Object> objects) {
        // 处理每个接收到的对象
    }

    @Override
    public void onError(Throwable e) {
        // 发生错误时调用
    }

    @Override
    public void onComplete() {
        // 当Observable完成发送所有对象时调用
    }
});