compose_flow.kt

@Composable
fun <T> observe(
  data: Flow<T>,
  transform: (T) -> T = { it }
): T? {
  var result: T? by state { null }
  val action: suspend (T) -> Unit = remember { { result = transform(it) } }

  onCommit(data) {
    val job = GlobalScope.launch(Dispatchers.Main) {
      data.collect(action)
    }
    onDispose { job.cancel() }
  }

  return result
}