subscribeTopic

open suspend override fun subscribeTopic(topic: String)(source)