Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- @Test
- fun testRegistryServiceWithExistingDependency(testContext: TestContext) {
- // register a bundle where the dependency does not exist yet
- cleanDatabase()
- val async = testContext.async()
- launch {
- awaitEvent<HttpClientResponse> { handler -> vertx.createHttpClient().post(8080, "localhost", "/bundle/", handler).end(getTestRequestWithNotExistingDependency()) }
- awaitEvent<HttpClientResponse> { handler -> vertx.createHttpClient().post(8080, "localhost", "/bundle/", handler).end(getSimpleTestRequest()) }
- val result = awaitEvent<HttpClientResponse> { handler -> vertx.createHttpClient().get(8080, "localhost", "/bundles/", handler).end() }
- println(result.statusCode())
- result.handler { event ->
- logger.info("handler was called")
- }
- result.bodyHandler { body ->
- logger.info("body handler was called")
- println(body)
- async.complete()
- }
- .exceptionHandler { throwable ->
- logger.error(throwable)
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement