我正在从网络获取对象列表<>。我想将所有对象传递给一个函数,并在所有列表都用尽时得到结果。
这就是我现在正在做的事情。
Observable.fromIterable(shortLinksList)
.filter(shortLinkAlreadyExistsPredicate)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(this::insertLink);
当所有列表都用完时,我如何收到通知?
最佳答案
如果您只想收到通知,可以在您的订阅者
上使用onCompleted
。
如果您想要包含先前发出的所有项目的通知,请使用 toList()运算符收集从 Observable 发出的所有项目并获取包含对象列表的单个通知。
关于java - 如何从 Observable.fromIterable() 获得最终结果?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42755426/