使用 rxjava2 循环遍历 arraylist

Question

我有一个包含一组 objects.I 的数组列表，我想使用 rxjava，这样我就可以在 onSubscribe 方法中循环遍历列表，而不是一次获取整个列表每个列表项一次 1

Answer 1

实际上是 Observable.fromIterable 成功了，一次 Observable.from returns 整个数组。

Answer 2

如果您使用 android，建议也使用 retrolambda 和 rxandroid。 您可以删除过滤器 ofc。 此行：.subscribeOn(Schedulers.newThread()) 也仅适用于 android。

List<Integer> array = new ArrayList<>();

array.add(0);
array.add(1);
array.add(2);
array.add(5);
array.add(10);

Observable.fromIterable(array)
    .subscribeOn(Schedulers.newThread())
    .filter(integer -> integer % 2 == 0)
    .subscribe(integer -> Log.e(TAG, "" + integer));