4.0.0.CR2

Author: aesteve

README.md

@@ -12,6 +12,7 @@ Artifacts are published [here](https://search.maven.org/artifact/io.reactiverse/
 
 | Project | Vert.x | AWS sdk |
 | ------- | ------ | ------- |
+|  1.0.0  | 4.0.0  | 2.15.40 |
 |  0.7.0  | 3.9.4  | 2.15.23 |
 |  0.6.0  | 3.9.2  | 2.14.7  |
 |  0.5.1  | 3.9.2  | 2.13.6  |

build.gradle.kts

@@ -1,6 +1,6 @@
-val vertxVersion = "4.0.0.CR1"
-val awsSdkVersion = "2.15.23"
-val junit5Version = "5.4.0"
+val vertxVersion = "4.0.0.CR2"
+val awsSdkVersion = "2.15.40"
+val junit5Version = "5.7.0"
 val logbackVersion = "1.2.3"
 val integrationOption = "tests.integration"
 
@@ -72,8 +72,7 @@ dependencies {
     testImplementation("ch.qos.logback:logback-classic:$logbackVersion")
     testImplementation("ch.qos.logback:logback-core:$logbackVersion")
     testImplementation("software.amazon.awssdk:aws-sdk-java:$awsSdkVersion")
-
-    testCompile("org.junit.jupiter:junit-jupiter-engine:$junit5Version")
+    testImplementation("org.junit.jupiter:junit-jupiter-engine:$junit5Version")
 }
 
 java {

src/main/java/io/reactiverse/awssdk/VertxNioAsyncHttpClient.java

@@ -8,6 +8,7 @@
 import io.vertx.core.http.HttpClient;
 import io.vertx.core.http.HttpClientOptions;
 import io.vertx.core.http.HttpClientRequest;
+import io.vertx.core.http.HttpClientResponse;
 import io.vertx.core.http.HttpHeaders;
 import io.vertx.core.http.HttpMethod;
 import io.vertx.core.http.RequestOptions;
@@ -76,11 +77,13 @@ void executeOnContext(AsyncExecuteRequest asyncExecuteRequest, CompletableFuture
             return;
           }
           HttpClientRequest vRequest = ar.result();
-          vRequest.onFailure(error -> {
-            responseHandler.onError(error);
-            fut.completeExceptionally(error);
-          });
-          vRequest.onSuccess(vResponse -> {
+          vRequest.response(res -> {
+            if (res.failed()) {
+              responseHandler.onError(res.cause());
+              fut.completeExceptionally(res.cause());
+              return;
+            }
+            HttpClientResponse vResponse = res.result();
             final SdkHttpFullResponse.Builder builder = SdkHttpResponse.builder()
               .statusCode(vResponse.statusCode())
               .statusText(vResponse.statusMessage());