问题描述
在我的项目中，我自己编写 View 和 viewmodel 并共享 Repository、Db、networking 。
当用户从一个屏幕导航到另一个屏幕时，我想取消当前在第一个屏幕中运行的所有网络请求或其他繁重的后台操作。
Repository 类中的示例函数：
@Throws(Throwable::class)
suspend fun fetchData(): List<String>
在 Android 的 viewmodel 中，我可以使用 viewmodelScope 自动取消所有活动的协程。但是如何在 iOS 应用中取消这些任务？
解决方法
假设对象会话是一个 URLSession 实例，您可以通过以下方式取消它：
session.invalidateAndCancel()
您可能有 3 个选择：
-
如果您使用某种响应式设置 iOS 端（例如 MVVM），您可以选择忽略取消。取消只会节省最少的工作量。
-
将您对共享代码的 iOS 调用包装在 iOS 反应式框架（例如组合）中，并使用 iOS 框架处理取消。共享的工作仍然会完成，但视图不会更新，因为您的 iOS 框架在离开屏幕时正在处理取消。
-
使用
Flow和 this closable helper
我没有找到任何关于此的第一方信息或任何好的解决方案，所以我想出了我自己的。很快，它将需要将存储库挂起函数转换为返回类型为具有 cancel() 成员函数的自定义接口的常规函数。函数将动作 lambda 作为参数。在实现方面，将启动协程并保留对 Job 的引用，以便稍后需要停止后台工作时接口 cancel() 函数将取消 job。
此外，由于很难从 NSError 读取错误类型（万一发生），我使用自定义类包装返回数据，该类将保存错误消息和类型。早些时候，我询问了相关的 question，但没有得到好的答案，因为 ViewModel 在每个平台中都是原生编写的。
如果您发现这种方法有任何问题或有任何想法，请分享。
自定义返回数据包装器：
class Result<T>(
val status: Status,val value: T? = null,val error: KError? = null
)
enum class Status {
SUCCESS,FAIL
}
data class KError(
val type: ErrorType,val message: String? = null,)
enum class ErrorType {
UNAUTHORIZED,CANCELED,OTHER
}
自定义界面
interface Cancelable {
fun cancel()
}
存储库界面：
//Convert this code inside of Repository interface:
@Throws(Throwable::class)
suspend fun fetchData(): List<String>
//To this:
fun fetchData(action: (Result<List<String>>) -> Unit): Cancelable
代码库实现：
override fun fetchData(action: (Result<List<String>>) -> Unit): Cancelable = runInsideOfCancelableCoroutine {
val result = executeAndHandleExceptions {
val data = networkExample()
// do mapping,db operations,etc.
data
}
action.invoke(result)
}
// example of doing heavy background work
private suspend fun networkExample(): List<String> {
// delay,thread sleep
return listOf("data 1","data 2","data 3")
}
// generic function for reuse
private fun runInsideOfCancelableCoroutine(task: suspend () -> Unit): Cancelable {
val job = Job()
CoroutineScope(Dispatchers.Main + job).launch {
ensureActive()
task.invoke()
}
return object : Cancelable {
override fun cancel() {
job.cancel()
}
}
}
// generic function for reuse
private suspend fun <T> executeAndHandleExceptions(action: suspend () -> T?): Result<T> {
return try {
val data = action.invoke()
Result(status = Status.SUCCESS,value = data,error = null)
} catch (t: Throwable) {
Result(status = Status.FAIL,value = null,error = ErrorHandler.getError(t))
}
}
ErrorHandler：
object ErrorHandler {
fun getError(t: Throwable): KError {
when (t) {
is ClientRequestException -> {
try {
when (t.response.status.value) {
401 -> return KError(ErrorType.UNAUTHORIZED)
}
} catch (t: Throwable) {
}
}
is CancellationException -> {
return KError(ErrorType.CANCELED)
}
}
return KError(ErrorType.OTHER,t.stackTraceToString())
}
}