chirag
12/13/2017, 10:09 AMdave08
12/13/2017, 11:38 AMsuspend fun ConfigRetriever.getConfig(): JsonObject =
awaitResult { getConfig(it) }
fun <T> EventBus.consumer(vertx: Vertx, address: String): ReceiveChannelHandler<Message<T>> =
vertx.receiveChannelHandler<Message<T>>().apply {
consumer<T>(address, this)
}
suspend fun <T> EventBus.awaitSend(address: String, message: Any): Message<T> = awaitResult {
send<T>(address, message, it)
}
dave08
12/13/2017, 11:41 AM