0

希望你们做得好，我一直在使用 RxJava 和 Retrofit 开发个人 Android 项目。PublishSubject这是对 GitHub 问题的搜索请求，当用户单击搜索按钮并使用对象发出搜索文本时，我收到了用户的输入。

button.setOnClickListener(view -> {
    publishSubject.onNext(editText.getText().toString());
});

我将这个发射映射到这样的Observable使用改造

publishSubject.concatMap(dataModel::getIssues)
              .subscribeOn(Schedulers.computation())
              .observeOn(AndroidSchedulers.mainThread())
              .subscribe(this::loadData, this::onError);

public Observable<List<Issue>> getIssues(String queryText) {
    String[] query_params = queryText.split("/");
    return gitHubApiService.getIssues(query_params[0], query_params[1], "open");
}

List结果我期待Issues

public void loadData(List<Issue> issues) {
    mProgressDialog.setVisibility(View.INVISIBLE);

    if( issues.size() == 0) {
        noIssueText.setVisibility(View.VISIBLE);
    } else {
        mRecyclerView.setVisibility(View.VISIBLE);
        mIssuesList.clear();
        mIssuesList.addAll(issues);
        mAdapter.notifyDataSetChanged();
    }
}

但我的代码似乎有一些实现问题，因为它从不从网络发出任何东西，甚至没有调用错误。我已经使用Observable从 Retrofit API 获得的相同示例进行了测试，因此没有改造错误，因此我认为我的concatMap逻辑存在一些问题。任何帮助都感激不尽

4

1 回答 1

2

在第一次解析时，我认为您可能正在主线程中进行网络调用。您是否尝试过以下操作？

public Observable<List<Issue>> getIssues(String queryText) {
  String[] query_params = queryText.split("/");
  return gitHubApiService.getIssues(query_params[0], query_params[1], "open")
       .subscribeOn(Schedulers.io());
}

问题是，您的onClickListener回调在主线程上运行，并且可观察管道中没有其他上下文切换。

于 2017-05-19T17:58:37.553 回答