LiveDataExtensions.kt

import androidx.lifecycle.LiveData
import androidx.lifecycle.Observer
import java.util.concurrent.CountDownLatch
import java.util.concurrent.TimeUnit

fun <T> LiveData<T>.blockingObserve(): T? {
    val countDownLatch = CountDownLatch(1)

    var result: T? = null
    val observer = Observer<T> {
        result = it
        countDownLatch.countDown()
    }

    observeForever(observer)

    countDownLatch.await(2, TimeUnit.SECONDS)
    return result
}