android - 将 T 的序列转换为 List在无限流中

Question

我正在使用 RxBinding 来处理我的应用程序中的搜索。如何将结果作为项目列表获取？toList().toBlocking().single()不是无限流中的选项，因为onComplete()永远不会被调用。有任何想法吗？谢谢。

RxSearchView.queryTextChanges(searchView)
                    .filter(queryString -> queryString.length() > 3 || queryString.length() == 0)
                    .debounce(500, TimeUnit.MILLISECONDS)
                    .map(CharSequence::toString)
                    .flatMap(s -> Observable.from(fishPlaces)
                                            .filter(fishPlace -> fishPlace.getName().toLowerCase().contains(s.toLowerCase())))
                    .subscribe(fishPlace -> { **// HOW TO GET A LIST<FISHPLACE> HERE???** }, throwable -> {});

Answer 1

但是，可以将平面图中的 observable 设置为阻塞。因此，您可以只使用 map() 而不是 flatmap() 并在可观察的fishplaces 上执行 toList() 。

.map(s -> Observable.from(fishPlaces).filter(fP-> foo(s, fP)).toList()))

Answer 2

我猜你想要的是匹配特定搜索字符串的“fishPlaces”列表。

我还猜想“fishPlaces”的数量是有限的，否则列出它是没有意义的。

通过细微的更改（没有实际运行代码），我想以下方法会起作用：

RxSearchView.queryTextChanges(searchView)
                    .filter(queryString -> queryString.length() > 3 || queryString.length() == 0)
                    .debounce(500, TimeUnit.MILLISECONDS)
                    .map(CharSequence::toString)
                    .map(s -> Observable.from(fishPlaces)
                                        .filter(fishPlace -> fishPlace.getName().toLowerCase().contains(s.toLowerCase()))
                                        .toList().toBlocking().single())
                    .subscribe(fishPlaces -> { /* Go fishing! */ }, throwable -> {});