Converts Decompose Value to StateFlow

DecomposeUtils.kt

fun <T : Any> Value<T>.toStateFlow(lifecycle: Lifecycle): StateFlow<T> {
   val state = MutableStateFlow(this.value)

   if (lifecycle.state != Lifecycle.State.DESTROYED) {
       val observer = { value: T -> state.value = value }
       subscribe(observer)
       lifecycle.doOnDestroy {
           unsubscribe(observer)
       }
   }

   return state
}

There is no unsubscribe function (at least in newer versions of Decompose). You may consider using this implementation instead:

fun <T : Any> Value<T>.toStateFlow(lifecycle: Lifecycle): StateFlow<T> {
    val state = MutableStateFlow(this.value)

    if (lifecycle.state != Lifecycle.State.DESTROYED) {
        val observer = { value: T -> state.value = value }
        val cancellation = subscribe(observer)
        lifecycle.doOnDestroy {
            cancellation.cancel()
        }
    }

    return state
}