调解员实时数据已更改未被调用

Question

在我的应用程序中，我正在尝试使用MediatorLiveData来监听对实时数据的更改。由于涉及数据库操作，我使用这样的执行器服务。

MediatorLiveData<Content> mediatorLiveData = new MediatorLiveData<>();
appExecutors.diskIO().execute(() -> {
long id = contentDao.insert(content);
Log.i("LIVE", id + "");
LiveData<Content> content = contentDao.getContentById(id);
mediatorLiveData.addSource(content, new Observer<Content>() {
@Override
public void onChanged(@Nullable Content content) {
Log.i("LIVE", "FIRED");
}
});
});

首先，我尝试将一个新的内容对象插入到数据库中。我得到插入对象的id，我在下一行记录。我得到一些id，这很好。在此之后，我使用 id 查询同一对象。查询返回实时数据。(如果我此时使用 content.getValue((，我会得到 null。

然后我使用MediatorLiveData监听此实时数据中的更改。不幸的是，mediatorLiveData 的 onChange 方法从未被触发。因此，日志也不会打印。

这是我的内容道课

@Dao
public interface ContentDao {
@Insert
long insert(Content content);
@Query("SELECT * FROM my_table WHERE id = :id")
LiveData<Content> getContentById(long id);
}

我不明白我做错了什么。有人可以帮忙吗？谢谢！！

编辑：澄清一下，这就是代码的外观。

return new NetworkBoundResource<Content, CreateContent>(appExecutors) {
@Override
protected void saveCallResult(@NonNull CreateContent item) {
//Something
}
@Override
protected boolean shouldCall(@Nullable Content data) {
//Something;
}
@Override
protected LiveData<Content> createDbCall() {
MediatorLiveData<Content> mediatorLiveData = new MediatorLiveData<>();
appExecutors.diskIO().execute(() -> {
long id = contentDao.insert(content);
Log.i("LIVE", id + "");
LiveData<Content> content = contentDao.getContentById(id);
mediatorLiveData.addSource(content, new Observer<Content>() {
@Override
public void onChanged(@Nullable Content c) {
Log.i("LIVE", "FIRED");                                                
mediatorLiveData.removeSource(content);
mediatorLiveData.postValue(c);
}
});
});
return mediatorLiveData;
}
@NonNull
@Override
protected LiveData<ApiResponse<CreateContent>> createCall() {
//Something
}
}.asLiveData();

该值将返回到构造函数。

@MainThread
public NetworkBoundResource(AppExecutors appExecutors) {
this.appExecutors = appExecutors;
result.setValue(Resource.loading(null));
//TODO:: Add method to check if data should be saved. This should apply for search data.
LiveData<ResultType> dbSource = createDbCall();
result.addSource(dbSource, data -> {
result.removeSource(dbSource);
if (shouldCall(data)) {
fetchFromNetwork(dbSource);
} else {
result.addSource(dbSource, newData -> setValue(Resource.success(newData)));
}
});
}

Answer 1

如前所述，您需要确保mediatorLiveData附加了一个活动的观察者。

如果您查看 addSource 方法，它会在订阅源之前检查是否附加了任何活动观察者。

https://github.com/aosp-mirror/platform_frameworks_support/blob/d79202da157cdd94c2d0c0b6ee57170a97d12c93/lifecycle/livedata/src/main/java/androidx/lifecycle/MediatorLiveData.java#L95

Answer 2

如果有人重新初始化调解器实时数据，则只会观察旧对象，不会观察到新对象。

也就是说，不要这样做：

1. 观察 myViewModel.observe(....(

2. 尝试为调解器分配新内存 myMediatorObj = new MediatorLiveData<>((;这可能是问题所在。如果您有这样的行，请尝试删除。

//在此之后，任何设置为对象 myMediatorObj 的内容都不会被观察到

如果您尝试重置数据，请传入一些表示空/空/休息的数据。