Kotlin中Flow内挂起函数的执行顺序及修正方案咨询

当在协程中调用listenForCompletion().collect { ... }时，代码会按以下顺序执行：

• 协程进入flow的构建Lambda，先初始化isTaskCompleted为false
• 调用挂起函数doWork()：协程会挂起，直到耗时任务执行完成，将返回结果赋值给taskStatus
• 判断taskStatus是否等于1：
  • 若满足条件，调用挂起函数sendTaskStatus(status: Int)：协程再次挂起，直到网络请求完成，得到返回值isDataSent
  • 如果isDataSent为true，修改isTaskCompleted为true
• 调用emit(isTaskCompleted)，将结果发送给collect的下游处理逻辑
• flow执行完毕，协程继续执行后续代码

• 拼写错误：taskStaus应为taskStatus
• 类型不匹配：flow泛型声明为<String>，但emit的是Boolean类型，编译会报错
• 变量不可修改：isTaskCompleted用val声明，无法重新赋值，逻辑无法正常执行
• 函数调用错误：调用sendTaskStatus()时未传入要求的status参数
• 未定义变量：代码中task变量未声明，属于示例遗漏的占位逻辑

修正上述问题后的代码如下，同时补充了合理的模拟逻辑：

// 示例任务类，用于模拟任务状态
data class Task(val isSuccessful: Boolean)

suspend fun doWork(): Int {
    // 模拟耗时任务，比如延迟2秒
    delay(2000)
    val task = Task(isSuccessful = true)
    return if (task.isSuccessful) 1 else -1
}

suspend fun sendTaskStatus(status: Int): Boolean {
    // 模拟网络请求，延迟1秒
    delay(1000)
    val task = Task(isSuccessful = true)
    return task.isSuccessful
}

fun listenForCompletion() = flow<Boolean> {
    var isTaskCompleted = false // 改为var支持修改
    val taskStatus = doWork()
    if (taskStatus == 1) {
        val isDataSent = sendTaskStatus(taskStatus) // 传入必填参数
        if (isDataSent) {
            isTaskCompleted = true
        }
    }
    emit(isTaskCompleted)
}

// 调用示例
fun main() = runBlocking {
    listenForCompletion().collect { isCompleted ->
        println("最终任务完成状态：$isCompleted")
    }
}

内容的提问来源于stack exchange，提问作者Mr. Techie