class TopicRegistrar : CoroutineScope
(source)
<init> |
TopicRegistrar(coroutineContext: CoroutineContext = Dispatchers.IO, connector: DefaultUdpConnector) |
coroutineContext |
val coroutineContext: CoroutineContext |
delayRegTopic |
suspend fun delayRegTopic(requestId: Bytes, topic: Bytes, waitTime: Long): Unit |
registerTopic |
suspend fun registerTopic(topic: Bytes, withDelay: Boolean = false): Unit |