rxjava2 在间隔和 toList 之后不调用 onSuccess

Question

这是我使用的示例代码：

Observable.interval(0, 30, TimeUnit.SECONDS)
            .flatMap(new Function<Long, ObservableSource<Long>>() {
                @Override
                public ObservableSource<Long> apply(@NonNull Long aLong) throws Exception {
                    List<Long> list = new ArrayList<>();
                    list.add(aLong);
                    list.add(aLong);
                    list.add(aLong);
                    list.add(aLong);
                    return Observable.fromIterable(list);
                }
            })
            .filter(new Predicate<Long>() {
                @Override
                public boolean test(@NonNull Long aLong) throws Exception {
                    return true;
                }
            })
            .toList()
            .subscribe(new DisposableSingleObserver<List<Long>>() {
                @Override
                public void onSuccess(@NonNull List<Long> longs) {
                    Log.e("test", "onSuccess");
                }
                @Override
                public void onError(@NonNull Throwable e) {
                    Log.e("test", "onError");
                }
            });

我是 rxjava2 的新手，我不知道为什么在这种情况下不调用 onSuccess 或 onError。任何帮助，不胜感激。

Answer 1

那是因为你有一个源 可观察 ( interval() ( 发出无限数量的项目，并且没有什么能阻止它顺流而下。
toList()必须等待onComplete()才能知道流何时停止并收集它发出到列表中的所有项目。
换句话说，由于您的可观察对象有无限项，因此您无法将其收集到列表中，因为它是有限集合。 可观察量将不执行任何操作，因为它将永远等待所有项目。