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

Question

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

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

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

当所有列表都用完时，我怎样才能得到通知？

Answer 1

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