0

我是 RxJava 的新手，那里有很多示例和答案，但是我无法拼凑一些可以解决我所有问题的东西。

下面的代码似乎可以正常工作，只是偶尔会出现乱序的结果。所以我想我需要引入一个 switchMap，但我不确定具体在哪里，我想知道我是否还没有让事情变得不必要的复杂，比如订阅 RxBinding 并单独订阅网络调用是否很奇怪？

view.autocompleteText() 是一个 RxBinding。我想从中获取文本，调用改造服务，并用结果更新视图，所有的花里胡哨，比如显示/隐藏微调器，以及网络调用的错误处理，这不会杀死整个事情并使我的文本框无响应。 

private void handleAutocompleteText() {
    mCompositeDisposable.add(view.autocompleteText()
        .debounce(400, TimeUnit.MILLISECONDS)
        .filter(s -> s.length() >= resources.getAutocompleteThreshold())
        .observeOn(threads.main())
        .doOnNext(s -> view.setProgressVisible(true))
        .subscribe(s -> {
            mCompositeDisposable.add(mAutocompleteService.query(s.toString())
                .subscribeOn(threads.io())
                .observeOn(threads.main()).toObservable()
                .retry(3)
                .doOnNext(response -> {
                    if (response.getStatus() != 200)
                        throw new RuntimeException("Server error " + response.getStatus());
                })
                .map(response -> response.getData())
                .subscribe(items -> {
                    view.setProgressVisible(false);
                    view.updateList(items);
                }, error -> {
                    view.setProgressVisible(false);
                    view.showMessage(resources.getListError());
                }));
            }, error -> {
                view.setProgressVisible(false);
                view.showMessage(resources.getListError());
            }
        )
    );
}

有没有更好的方法来做到这一点，我在哪里可以引入一个 switchMap 来丢弃任何飞行中的搜索，只用最后一个结果更新视图？如果答案完全不同，我真的很感激演练。

提前致谢！！

4

1 回答 1

2

我不确定这是你想要的。但它可能会给你提示和解决方案。让我们看看代码。从视图中switchMap获取参数并更改observable为resrofit observable。然后它返回来自 的响应API call。毕竟，您可以收到响应并使用响应。

如果代码不起作用，请告诉我。

mCompositeDisposable.add(
        view
                .autocompleteText()
                .debounce(400, TimeUnit.MILLISECONDS)
                .filter({ s -> s.length() >= resources.getAutocompleteThreshold() })
                .observeOn(threads.main())
                .doOnNext({ s -> view.setProgressVisible(true) })
                .map({ s -> s.toString())}
                .switchMap({ text -> mAutocompleteService.query(text))}
                .subscribeOn(threads.io())
                .observeOn(threads.main())
                .retry(3)
                .doOnNext({ response ->
                    if (response.getStatus() !== 200)
                        throw RuntimeException("Server error " + response.getStatus())
                })
                .map({ response -> response.getData() })
                .subscribe({ items ->
                    view.setProgressVisible(false)
                    view.updateList(items)
                }, { error ->
                    view.setProgressVisible(false)
                    view.showMessage(resources.getListError())
                })
)
于 2019-02-15T04:20:02.847 回答