Add support for Vertx Core

src/org/kotlin/community/http/benchmarks/Benchmarks.kt

@@ -14,7 +14,7 @@ import org.kotlin.community.http.benchmarks.ninjaframework.*
 import org.kotlin.community.http.benchmarks.rapidoid.*
 import org.kotlin.community.http.benchmarks.spark.*
 import org.kotlin.community.http.benchmarks.undertow.*
-import org.kotlin.community.http.benchmarks.vertx.*
+import org.kotlin.community.http.benchmarks.vertxweb.*
 
 fun main(args: Array<String>) {
     benchmark(args) {
@@ -48,6 +48,7 @@ private fun BenchmarkSettings.setup() {
     run<SparkBenchmark>()
     run<UndertowBenchmark>()
     run<VertxBenchmark>()
+    run<VertxWebBenchmark>()
     run<RapidoidBenchmark>()
 }
 

src/org/kotlin/community/http/benchmarks/vertx/VertxBenchmark.kt

@@ -14,16 +14,9 @@ fun main(args: Array<String>) {
 open class VertxBenchmark : HttpBenchmarkBase() {
     val vertx = Vertx.vertx()
     override fun startServer(port: Int) {
-        val router = Router.router(vertx).apply {
-            get("/").handler { request ->
-                request.response().putHeader("content-type", "text/plain").end("Hello")
-            }
-            //get().handler(StaticHandler.create("public"))
-        }
-
         val f = CompletableFuture<Unit>()
-        vertx.createHttpServer().requestHandler {
-            router.accept(it)
+        vertx.createHttpServer().requestHandler { request ->
+            request.response().putHeader("content-type", "text/plain").end("Hello")
         }.listen(port) {
             f.complete(Unit)
         }

src/org/kotlin/community/http/benchmarks/vertxweb/VertxWebBenchmark.kt

@@ -0,0 +1,36 @@
+package org.kotlin.community.http.benchmarks.vertxweb
+
+import io.vertx.core.*
+import io.vertx.ext.web.*
+import org.kotlin.community.http.benchmarks.*
+import java.util.concurrent.*
+
+fun main(args: Array<String>) {
+    benchmark(args) {
+        run<VertxWebBenchmark>()
+    }
+}
+
+open class VertxWebBenchmark : HttpBenchmarkBase() {
+    val vertx = Vertx.vertx()
+    override fun startServer(port: Int) {
+        val router = Router.router(vertx).apply {
+            get("/").handler { request ->
+                request.response().putHeader("content-type", "text/plain").end("Hello")
+            }
+            //get().handler(StaticHandler.create("public"))
+        }
+
+        val f = CompletableFuture<Unit>()
+        vertx.createHttpServer().requestHandler {
+            router.accept(it)
+        }.listen(port) {
+            f.complete(Unit)
+        }
+        f.join()
+    }
+
+    override fun stopServer() {
+        vertx.close()
+    }
+}