kotlin - 如何从一个地方收集流量并从另一个地方取消流量？

Question

我有一个流程:

fun startCountingTimer(coroutineContext: CoroutineContext, leftSeconds: Int): Flow<Int> {
return flow {
    for (i in leftSeconds downTo 0) {
        delay(1000)
        emit(i)
    }
 }
}

我想从一个地方收集它:

startWaitingTimer().collect {
    ...
}

并从另一个取消:

startWaitingTimer().cancel()

怎么做？

Answer 1

使用 launchIn 返回 Job 。完成后， cancel 工作。

val job = startWaitingTimer(10).onEach { ... }.launchIn(scope)

// Later...
job.cancel()