class FlowSource<T>(initialValue: T) {
    private val chan = ConflatedBroadcastChannel<T>().apply { post(initialValue) }

    var value = initialValue
        set(value) {
            field = value
            chan.post(value)
        }

    val flow: Flow<T> = chan.asFlow()

    private fun SendChannel<T>.post(value: T) {
        GlobalScope.launch { send(value) }
    }
}