verticleStubs.kt

//..FileHandler Verticle
router.post("/fileUpload").handler(BodyHandler.create().setMergeFormAttributes(true)).handler {
    println(it.fileUploads().size)


    it.fileUploads().forEach({
        println(it.fileName())
    })

    it.response().end(
            JsonObject()
                    .put("message", "Success")
                    .encode())
}

//..GatewayVerticle Stub
private fun setupRoutes(router : Router, serviceDiscovery: ServiceDiscovery) : Router {
      router.get("/health") { ctx ->
          ctx.response().end("OK")
      }
      router.post("/upload").handler({uploadHandler(it, serviceDiscovery)})
      return router
      }

      private fun uploadHandler(ctx: RoutingContext, serviceDiscovery: ServiceDiscovery) {
      fun onError(throwable: Throwable) = ctx.run {
          response().statusCode=HttpResponseStatus.FAILED_DEPENDENCY.code()
          response().close()
      }
      fun onSuccess(webClient: WebClient) = webClient.post("/fileUpload").sendStream(ctx.request()) { response ->

          ctx.response().end(response.result().bodyAsJsonObject().encodePrettily())
          webClient.close()
          ctx.response().close()
      }

      HttpEndpoint
              .rxGetWebClient(serviceDiscovery, JsonObject().put("name", "fileHandler"))
              .subscribeBy(onError = ::onError, onSuccess = ::onSuccess)
}