CoroutineWorker中的Kotlin协程
CoroutineWorker中的Kotlin协程
提问于 2019-05-22 20:13:58
我正在使用CoroutineWorker从房间数据库中获取一些数据，并将其发送到服务器，然后再次从数据库中删除该特定答案。我使用的是存储库模式。
class SendLocalAnswerToServer(ctx: Context, val params: WorkerParameters) :
CoroutineWorker(ctx, params) {
var useCaseHandler: UseCaseHandler? = null
var deleteAnswerFromTable: DeleteAnswerFromTable? = null
private var uploadAutoSavedAnswer: UploadAutoSavedAnswer? = null
val TAG:String= "SendLocalAnswerToServer"
override suspend fun doWork(): Result = runBlocking {
val questionID = params.inputData.getLong("questionID", 0)
val answerDao = UserDatabase.getDatabase(App.getInstance()).answerDao()
val answerAPIRepo = NetWorkUtil.provideRetrofit().create(AnswerAPI::class.java)
uploadAutoSavedAnswer = UploadAutoSavedAnswer(this, answerDao, answerAPIRepo)
deleteAnswerFromTable = DeleteAnswerFromTable(this, answerDao)
useCaseHandler = InjectionUtils.provideUseCaseHandler()
val requestValues = UploadAutoSavedAnswer.RequestValues()
requestValues.questionID = questionID
Log.e(TAG, " Main 1")
launch {
useCaseHandler!!.execute(uploadAutoSavedAnswer!!, requestValues,
object :
UseCase.UseCaseCallback<UploadAutoSavedAnswer.ResponseValues> {
override fun onSuccess(response: UploadAutoSavedAnswer.ResponseValues) {
Log.e(TAG, " onSuccess 1")
response.observable?.subscribeOn(Schedulers.io())?.observeOn(
AndroidSchedulers.mainThread())!!.subscribeWith(
object :
DisposableObserver<UserAnswerResponseModel>() {
override fun onComplete() {
}
override fun onNext(t: UserAnswerResponseModel) {
Log.e("TAG", " onNext ")
val requestValues = DeleteAnswerFromTable.RequestValues()
requestValues.answerID = t.question.id!!
useCaseHandler?.execute(
deleteAnswerFromTable!!,
requestValues,
object :
UseCase.UseCaseCallback<DeleteAnswerFromTable.ResponseValues> {
override fun onSuccess(
response: DeleteAnswerFromTable.ResponseValues) {
Log.e("TAG", " onSuccess 2")
// I want to return Result.Success() from here
}
override fun onError(
throwable: Throwable) {
// I want to return Result.Error() from here
}
})
}
override fun onError(e: Throwable) {
}
})
}
override fun onError(throwable: Throwable) {
}
})
}
Log.e(TAG, " MAIN 2")
Result.success()
}
}输出打印
E/SendLocalAnswerToServer: Main 1
E/SendLocalAnswerToServer: MAIN 2如何从上一次成功或返回方法中返回值，现在它进入第一个函数useCaseHandler!!.execute()，该函数进一步启动一个新线程，因此协程只是从那里返回任何解决方案，以便当完成整个api调用并从表中进一步删除时，只有它应该返回成功。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/56256564
复制相关文章
相似问题