java - 如何使用 RxJava 过滤列表并对所有匹配的元素进行分组

Question

我有一个非常大的列表，想在后台线程中对其执行简单的 Filter 操作，然后在操作结束时获取符合过滤条件的结果列表。

我对 RxJava 还是个新手，所以我正在努力让它工作。我所拥有的是以下内容(largeList 是一个 ArrayList，其中填充了 Item):

    Observable
            .fromIterable(largeList)
            .filter { it.name.contains(query) }
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeOn(Schedulers.io())
            .subscribe { ... }

当我订阅时，我得到一个Item，而不是所有通过过滤器的项目的完整列表。如何创建所有匹配结果的子列表？

Answer 1

使用 toList() 运算符。

对于给定的 Observable，它将收集传入的发射到一个列表中，然后将整个列表作为单个发射(通过 Single>)推送。

 Observable
                .fromIterable(largeList)
                .filter { it.name.contains(query) }
                .toList() 
                .observeOn(AndroidSchedulers.mainThread())
                .subscribeOn(Schedulers.io())
                .subscribe { ... }

此外，您还可以选择指定一个整数参数作为 capacityHint，这将优化 ArrayList 的初始化以大致预期项目数:

  Observable
                    .fromIterable(largeList)
                    .filter { it.name.contains(query) }
                    .toList(capacityHint)
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribeOn(Schedulers.io())
                    .subscribe { ... }