dave08
10/16/2017, 1:16 PMsuspend 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)
}
Code is a more readable...