android - 如何创建 Rx 搜索 View 来使用查询过滤回收器 View

Question

我想实现一个 Rx 搜索 View ，它将使用字符串过滤回收器 View ，并检查本地领域数据库并发出改造请求，然后组合所有结果而不重复？因此，换句话说:我想在搜索 View 中的文本更改事件上，使用输入字符串发出网络请求、数据库查询并与不重复的结果合并

这是我的初始代码:

RxSearchView.queryTextChanges(searchView)
            .filter(charSequence -> !TextUtils.isEmpty(charSequence))
            .throttleLast(100, TimeUnit.MILLISECONDS)
            .debounce(200, TimeUnit.MILLISECONDS)
            .onBackpressureLatest()
            .flatMap(charSequence -> userListPresenter.search(charSequence))
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeOn(Schedulers.io())
            .onErrorResumeNext(Observable.empty())
            .subscribe((Action1) response -> userListPresenter.showSearchResult((List<UserModel>) response));

userListPresenter.search(charSequence)) 应该返回一个没有重复的串联响应的可观察值，谢谢:)

userListPresenter.search(charSequence)):

Observable.create(subscriber -> {
        if (Utils.isNetworkAvailable(getContext())) {
            if (!subscriber.isUnsubscribed()) {
                subscriber.onNext(restApi.search(query));
                subscriber.onCompleted();
            }
        }).mergeWith(
                    Observable.create(subscriber -> {
        if (!subscriber.isUnsubscribed()) {
            subscriber.onNext(realmManager.getWhere(query));
            subscriber.onCompleted();
        }
    })).collect(HashSet::new, HashSet::add)
            .flatMap(Observable::from);

Answer 1

如果我正确理解了你的问题。有一个很好的方法来组合多个 Observables 的排放，看看 zip method 。 因此，您的搜索方法将如下所示:

public Observable<List<MyItem>> search(CharSequence query) {
    return Observable.zip(
                observeNetwork(query),
                observeRealm(query),
                new Func2<List<MyItem>, List<MyItem>, List<MyItem>>() {
                    @Override
                    public List<MyItem> call(List<MyItem> networkResult, List<MyItem> databaseResult) {
                        return merge(networkResult,databaseResult);
                    }
                }
            );
}

private Observable<List<MyItem>> observeRealm(CharSequence searchString) {
    return Observable.create( /* do your realm stuff */);
}

private Observable<List<MyItem>> observeNetwork(CharSequence searchString) {
    return return Observable.create( /* do your network stuff */);
}

private List<MyItem> merge(List<MyItem> networkResult, List<MyItem> databaseResult) {
    List<MyItem> result = new ArrayList<>();
    result.addAll(databaseResult);
    for(MyItem newItem : networkResult){
        if(!databaseResult.contains(newItem)){
            result.add(newItem);
        }
    }
    return result;
}