small refacto

reactiverse · Aug 30, 2020 · 906501c · 906501c
1 parent 18f6539
commit 906501c
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/src/test/java/io/reactiverse/awssdk/ProxyTest.java b/src/test/java/io/reactiverse/awssdk/ProxyTest.java
@@ -83,13 +83,14 @@ public void testGetThroughProxy(VertxTestContext ctx) throws Exception {
       .credentialsProvider(credentialsProvider);
     HttpClientOptions throughProxyOptions = new HttpClientOptions().setProxyOptions(new ProxyOptions().setHost(PROXY_HOST).setPort(PROXY_PORT));
     KinesisAsyncClient kinesis = VertxSdkClient.withVertx(builder, throughProxyOptions, vertx.getOrCreateContext()).build();
-    CompletableFuture<ListStreamsResponse> fut = kinesis.listStreams();
     assertEquals(proxyAccess.get(), 0, "Proxy access count should have been reset");
-    fut.handle((res, err) -> {
-      assertTrue(proxyAccess.get() > 0, "Requests should have been transferred through proxy");
-      ctx.completeNow();
-      return null;
-    });
+    kinesis
+      .listStreams()
+      .handle((res, err) -> {
+        assertTrue(proxyAccess.get() > 0, "Requests should have been transferred through proxy");
+        ctx.completeNow();
+        return null;
+      });
   }
 
 }