如何从Android中的WorkManager获取实时数据

Question

我正在尝试从WorkManager的doWork()方法进行API调用。我收到MutableLiveData，其中包含来自响应的列表。如何将此复杂对象设置为工作管理器的输出？

请在下面找到相同的实现：

class FetchWorkManager(context: Context, params: WorkerParameters): Worker(context, params) {
var postInfoLiveData: LiveData<List<PostInfo>> = MutableLiveData()
@SuppressLint("RestrictedApi")
override fun doWork(): Result {
fetchInfoFromRepository()
// Setting output data
val data = Data.Builder()
.putAll(postInfoLiveData)
//.put("liveData", postInfoLiveData)
.build()
return Result.success(data)
}

fun fetchInfoFromRepository() {
val retrofitRepository = RetrofitRepository()
postInfoLiveData = retrofitRepository.fetchPostInfoList()
}
}

谁能帮我解决这个问题？

Answer 1

我不确定，但它应该是这样的:)

workManager?.getWorkInfoByIdLiveData(oneTimeWorkRequest.id)
?.observe(this, Observer {
if (it?.state == null)
return@Observer
when (it.state) {
State.SUCCEEDED -> {
val successOutputData = it.outputData
}
State.FAILED -> {
val failureOutputData = it.outputData
}
}
})

Answer 2

从与成员Worker返回结果不是预期行为LiveData。Worker的结果应作为startWork方法的返回值返回。要使用一些数据构造Result对象ListenableWorker.Result.success可以使用方法。

const val WORKER_RESULT_INT = "WORKER_RESULT_INT"
class WorkerWithOutput(context: Context, params: WorkerParameters) : Worker(context, params) {
override fun doWork(): Result {
// do some work
return Result.success(Data.Builder().putInt(WORKER_RESULT_INT, 123).build())
}
}

要从外部获取这些数据，应使用getWorkInfoXXX方法之一。

fun getResult(context: Context, owner: LifecycleOwner, id: UUID) {
WorkManager.getInstance(context)
.getWorkInfoByIdLiveData(id)
.observe(owner, Observer {
if (it.state == WorkInfo.State.SUCCEEDED) {
val result = it.outputData.getInt(WORKER_RESULT_INT, 0)
// do something with result
}
})
}

活动或片段可以作为LifecycleOwner传递(具体取决于您的情况(。WorkRequest.getId用于获取id的工作。

值得注意的是，在这种情况下，有一些ListenableWorker.setProgressAsync也很有用。

Answer 3

我不确定这是否有效，因为我还没有尝试过。 我知道这是一个迟到的答案，但我鼓励你尝试使用CoroutineWorker 如下所示：

class MyWorker(context: Context, params: WorkerParameters):
CoroutineWorker(context, params){
override suspend fun doWork(): Result {
val data = withContext(Dispatchers.IO) {
// you can make network request here (best practice?)
return@withContext fetchInfoFromRepository()
// make sure that fetchInfoFromRepository() returns  LiveData<List<PostInfo>>
}

/* Then return it as result with a KEY (DATA_KEY) to use in UI. */
val result = workDataOf(DATA_KEY to data)
return Result.success(result)
}
}

参考： https://developer.android.com/topic/libraries/architecture/workmanager/advanced/coroutineworker