is there a more idiomatic way to do

val hotFlow = baseFlow.conflate().broadcastIn(this).asFlow()

?

@FlowPreview
@ExperimentalCoroutinesApi
fun main() = runBlocking<Unit> {
    val baseFlow = (1..10).asFlow().delayEach(1_000)
    val hotFlow = baseFlow.conflate().broadcastIn(this).asFlow()
    launch {
        hotFlow.collect {
            println("A: $it")
        }
    }

    delay(5_000)
    launch {
        hotFlow.collect {
            println("B: $it")
        }
    }
}

Not yet AFAIK.