Aidan Low
06/22/2022, 12:00 AMfun TestScope.observeStateFlows(
vararg stateFlows: StateFlow<Any?>,
block: () -> Unit
) {
val observationJobs = stateFlows.map { flow ->
launch {
flow.collect {}
}
}
try {
runCurrent()
block.invoke()
} finally {
observationJobs.forEach { it.cancel() }
}
}