Hi there 🙂 What is the best way to integrate Channels/Flow with LiveData ?

There is no official adapter yet

Thanks 🙂

for now you have to use ConflatedBroadcastChannel (or flow which uses conflated channel) to implement adapter for LiveData

ConflatedBroadcastChannel

is the closest thing to

LiveData

. You could create a

LiveData

subclass that wraps a

ConflatedBroadcastChannel

. You can also use the

liveData

function from

androidx.lifecycle:lifecycle-livedata-ktx

: https://developer.android.com/topic/libraries/architecture/coroutines#livedata

You could create a

LiveData

subclass that wraps a

ConflatedBroadcastChannel

I would rather create adapter

LiveData.asFlow()

and

Flow.asLiveData()

than use inheritance

Hey if you figure out a working solution consider posting 😉

suspend fun <T> BroadcastChannel<T>.asLiveData(): LiveData<T> {
    val liveData = MutableLiveData<T>()
    consumeEach { value ->
        liveData.postValue(value)
    }
    return liveData
}

this shoud work - will test it later

it will not work

What is the best way to fix that? Passing Scope as parameter?

Something like:

fun <T> BroadcastChannel<T>.consumeAsLiveData(scope: CoroutineScope): LiveData<T> {
    val liveData = MutableLiveData<T>()
    scope.launch { 
        consumeEach { 
            liveData.postValue(it)
        }
    }
    return liveData
}

there is a

liveData

coroutine builder function that you can use for this too: https://developer.android.com/topic/libraries/architecture/coroutines#livedata

fun <T> BroadcastChannel<T>.consumeAsLiveData(scope: CoroutineScope): LiveData<T> = liveData {
    consumeEach { 
        emit(it)
    }
}