LiveData 有两个来源？

Question

我想对不同来源使用相同的 LiveData。一个来自 API 调用，它是可观察的，另一个来自数据库，它是 LiveData。我希望能够做这样的事情：

private LiveData<List<Items>> items = new MutableLiveData<>();

// this one comes from an API and it's an observable
public void onApiItemsSelected(String name) {
 Disposable disposable = repository.getItemsFromApi(name)
 .observeOn(AndroidSchedulers.mainThread())
 .subscribe(itemsList -> {
     items.setValue(itemsList);
 });

 compositeDisposable.add(disposable);
}

// this one comes from the database and it's a livedata that I want to transform first
public void onDatabaseItemsSelected() {
 items = Transformations.map(repository.getItemsFromdatabase(), itemsList -> {
    List<Items> finalItemsList = new ArrayList<>();

    for (Item item : itemsList) {
      finalItemsList.add(itemsList.toSomething());
    }

    return finalItemsList;
 });
}

问题是 Transformation.map 总是返回一个 LiveData 并且为了使 items.setValue(itemsList) 项目需要是一个 MutableLiveData。我尝试使用 MediatorLiveData，但它调用了两个源并混合了所有内容。这不是我在这里需要的。我需要一个来源或另一个。有可能吗？

Answer 1

我认为您可以将此责任委托给您的存储库。

请参阅此open source project 和相关article 以了解更多信息。

基本上，存储库处理决定从哪个源获取数据的所有复杂性（请参阅JobRepository）。它将 rx Observable 暴露给 ViewModel（参见 JobsViewModel）。然后 ViewModel 所要做的就是更新LiveData：

private val presentation: MutableLiveData<Presentation> = MutableLiveData()

fun bind() {
        jobRepository.getJobs(true)
            .subscribeOn(Schedulers.io())
            .subscribe { resource: Resource<List<JobWithRelations>> ->
                when (resource) {
                    // commenting some parts for brevity ...
                    is Resource.ResourceFound -> {
                        presentation.postValue(Presentation(getApplication(), resource.data!!))
                    }
                    // ...
                }
            }.addTo(compositeDisposable)
    }

管理多个数据源很复杂。在构建此架构涉及的许多方面中，需要牢记的事项包括：

• 内存缓存过期策略
• 数据库缓存策略，例如，当用户离线时
• API 调用的限制和重试
• 当新数据来自网络时更新内存缓存或数据库的策略

Dropbox Store 是一个可以帮助您的库。有了它，您可以从他们的文档中构建您的数据源，如下例所示：

StoreBuilder
    .from(
        fetcher = nonFlowValueFetcher { api.fetchSubreddit(it, "10").data.children.map(::toPosts) },
        sourceOfTruth = SourceOfTrue.from(
            reader = db.postDao()::loadPosts,
            writer = db.postDao()::insertPosts,
            delete = db.postDao()::clearFeed,
            deleteAll = db.postDao()::clearAllFeeds
        )
    ).build()

然后在你的 ViewModel 中获取数据：

private val presentation: MutableLiveData<Presentation> = MutableLiveData()

lifecycleScope.launchWhenStarted {
  store.stream(StoreRequest.cached(key = key, refresh=true)).collect { response ->
    when(response) {
        // commenting some parts for brevity ...
        is StoreResponse.Data -> {
            presentation.postValue(response.value)
        }
        // ...
    }
  }
}

Answer 2

我不确定这是否是最佳做法，但我认为可以解决问题。

public void onDatabaseItemsSelected() {
items.value = repository.getItemsFromdatabase().value;
};

语法可能不准确，因为我对java知之甚少，我主要做kotlin。但问题是：当用户点击 Api 时，让你的 onApiItemsSelected() 运行，这将设置 items 的值，当用户点击数据库时，让 onDatabaseItemsSelected()运行，因此它将替换 repository.getItemsFromDatabase()

结果的 items 值