使用rxjava2遍历数组列表

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

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

public class RxJavaExample {
    public static void main(String[] args) {
        List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);

        Observable<Integer> observable = Observable.fromIterable(numbers);

        Observer<Integer> observer = new Observer<Integer>() {
            @Override
            public void onSubscribe(Disposable d) {
                // 可选的方法，在订阅时被调用
            }

            @Override
            public void onNext(Integer integer) {
                // 处理每个元素的逻辑
                System.out.println(integer);
            }

            @Override
            public void onError(Throwable e) {
                // 处理错误的逻辑
            }

            @Override
            public void onComplete() {
                // 处理完成的逻辑
            }
        };

        observable.subscribe(observer);
    }
}