如何在执行终端操作员之前让 kotlin 流程等到结束

Question

/**
* Does some work and return true to denote success
* false to denote failure
*/
suspend fun doWork(): Boolean {

    val processStatus = processWork()

    return processStatus.filter { status ->
                status == ProcessStatus.SUCCESS 
                || status == ProcessStatus.FAILURE
            }.map { filteredStatus ->
                filteredStatus == ProcessStatus.SUCCESS
            }.single()
}


/**
* Cretaes a channel in which different status will be offered
*/
suspend fun processWork(): Flow<ProcessStatus> {

    val channel = BroadcastChannel(Channel.BUFFERED)
    doThework(channel)
    return channel.asFlow()
}


/**
* Does some work in background thread
*/
fun doThework(channel: BroadcastChannel) {

    SomeSope.launch {

        //Cretae a coroutine 
        channel.offer(ProcessStatus.Status1)
        channel.offer(ProcessStatus.Status2)
        channel.offer(ProcessStatus.Status3)
        channel.offer(ProcessStatus.Status4)

        channel.offer(rocessStatus.SUCCESS)
        channel.close()
    }
}

以上是我的代码的简化版本。

我想要做的是，让doWork() 等到所有值都被释放，最后根据最后一个ProcessStatus.SUCCESS 或ProcessStatus.FAILURE 返回一个布尔值。

现在，上面代码的情况是，只要processWork() 返回流。 doWork() 调用包括single() 在内的所有操作员，因为工作仍在进行中 ProcessStatus.FAILURE 或 ProcessStatus.SUCCESS 仍然没有被释放，所以它给出了一个异常。

如何使doWork() return 语句等待并仅在流程完成时返回？

---

编辑 1：

原因，我必须使用频道是因为，这是 Android 代码的一部分，channel.offer() 实际上并不是上面示例中的新协同程序，而是从 Android BroadcastReceiver 调用.

由于流程很冷，我不希望用户离开 Activity 以阻止任务完成和通知。

Answer 1

看起来您可以使用toList 方法在处理它们之前收集所有值：

suspend fun doWork(): Boolean {

    val processStatus = processWork().toList()

    return processStatus.filter { status ->
                status == ProcessStatus.SUCCESS 
                || status == ProcessStatus.FAILURE
            }.map { filteredStatus ->
                filteredStatus == ProcessStatus.SUCCESS
            }.single()
}