Advertisement
Guest User

coroutines

a guest
Nov 23rd, 2017
62
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Kotlin 1.16 KB | None | 0 0
  1. @Test
  2.     fun testRegistryServiceWithExistingDependency(testContext: TestContext) {
  3.         // register a bundle where the dependency does not exist yet
  4.  
  5.         cleanDatabase()
  6.  
  7.         val async = testContext.async()
  8.         launch {
  9.             awaitEvent<HttpClientResponse> { handler -> vertx.createHttpClient().post(8080, "localhost", "/bundle/", handler).end(getTestRequestWithNotExistingDependency()) }
  10.             awaitEvent<HttpClientResponse> { handler -> vertx.createHttpClient().post(8080, "localhost", "/bundle/", handler).end(getSimpleTestRequest()) }
  11.             val result = awaitEvent<HttpClientResponse> { handler -> vertx.createHttpClient().get(8080, "localhost", "/bundles/", handler).end() }
  12.  
  13.             println(result.statusCode())
  14.             result.handler { event ->
  15.                 logger.info("handler was called")
  16.             }
  17.             result.bodyHandler { body ->
  18.  
  19.                 logger.info("body handler was called")
  20.                 println(body)
  21.                 async.complete()
  22.             }
  23.             .exceptionHandler { throwable ->
  24.                 logger.error(throwable)
  25.             }
  26.  
  27.            
  28.         }
  29.  
  30.  
  31.     }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement