java - 如何从 Observable.fromIterable() 获得最终结果？

Question

我正在从网络获取对象列表<>。我想将所有对象传递给一个函数，并在所有列表都用尽时得到结果。

这就是我现在正在做的事情。

Observable.fromIterable(shortLinksList)
            .filter(shortLinkAlreadyExistsPredicate)
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(this::insertLink);

当所有列表都用完时，我如何收到通知？

Answer 1

如果您只想收到通知，可以在您的订阅者上使用onCompleted。
如果您想要包含先前发出的所有项目的通知，请使用 toList()运算符收集从 Observable 发出的所有项目并获取包含对象列表的单个通知。