如何使用rxjava/改装正确等待/观察来自服务器的传入数据

Question

我在从服务器下载数据时遇到问题，更具体地说，我无法实现“等待/观察传入数据”行为。我想用来自服务器的列表填充我的回收视图和微调器，但要知道，这些方法返回空列表。我理解，问题是该方法在数据到达之前完成。

我已经检查了这两个相似的问题，但没有一个答案对我有用：

等待API调用使用RxJava和Retrofit完成

RXJava改造等待UI等待从API获取数据

我的代码：

应用程序编程接口：

@GET("/api/categories")
Observable<Response<JsonObject>> getCategories();

netWorker：

public List<String> getCat() {
    List<String> incomingDataSet = new ArrayList<>();
    
    compositeDisposable.add(
        apiConnector.getCategories()
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(response -> {
                if (response.code() >= 200 && response.code() < 300) {
                    JsonArray incomingArray = response.body().getAsJsonArray("category");
                    
                    for (int i = 0; i < incomingArray.size(); i++) {
                        incomingDataSet.add(incomingArray.get(i).getAsJsonObject().get("categoryname").toString().replaceAll("\"", ""));
                        Log.i("LOG", "downloadCategories response: " + incomingDataSet.toString());
                    }

                } else {
                    Log.i("LOG", "Response error: " + response.code());
                }
            })
    );

    Log.i("LOG", "getCat: " + incomingDataSet.toString());
    
    return incomingDataSet;
}

主要活动：

List<String> categorylist = new ArrayList<>();
categorylist = netWorker.getCat();
Log.i("LOG", "list:" + categorylist );

所以，我在日志中看到的是：

第一：

getCat：[]

列表：[]

然后：

下载类别响应：[cat1]

下载类别响应：[cat1、cat2]

下载类别响应：[cat1、cat2、cat3]

Answer 1

在doOnSubscribe（）中显示微调器，在doFinally（）中隐藏微调器。将填充RecyclerView的代码放入subscribe（）中，以便在数据到达时填充它。否则，您只会在主线程上获得空的新列表，并且不会进一步更新RecyclerView。