dave08
fun getTopics() = buildSequence { yield(kafka.getTopic()) // This suspends until next value is requested }