You can do it today with some integration glue

Flow

is a bit of a challenge at the moment due to some incompatibilities between the version of the IR compiler the latest compose plugin is using and generating suspending code, but some clever module separation can work around it for now. We're pretty anxious to see these bugs get fixed soon

LiveData

is a little bit easier, let me see if I can dig up the snippet to use as an

observe()

effect for it

there it is:

fun <T> observe(data: LiveData<T>) = effectOf<T?> {
    val result = +state<T?> { data.value }
    val observer = +memo { Observer<T> { result.value = it } }

    +onCommit(data) {
        data.observeForever(observer)
        onDispose { data.removeObserver(observer) }
    }

    result.value
}

usage is:

val currentValue = +observe(myLiveData)

you'll get a recomposition each time the

LiveData

value changes, and the

LiveData

will have an active observer for the duration of that composition

which is to say, the `LiveData`s returned by room queries will continue updating until that part of your compose UI goes away