Update to CompositeFuture changes

Author: vietj

vertx-mssql-client/src/test/java/io/vertx/mssqlclient/MSSQLQueriesTest.java

@@ -20,6 +20,7 @@
 import io.vertx.ext.unit.junit.RepeatRule;
 import io.vertx.ext.unit.junit.VertxUnitRunner;
 import io.vertx.sqlclient.Row;
+import io.vertx.sqlclient.RowSet;
 import io.vertx.sqlclient.Tuple;
 import io.vertx.sqlclient.data.NullValue;
 import org.junit.After;
@@ -35,6 +36,7 @@
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.List;
+import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
 import static org.hamcrest.CoreMatchers.instanceOf;
@@ -185,14 +187,14 @@ public void testExecuteStoredProcedure(TestContext ctx) {
 
   @Test
   public void testQuerySequences(TestContext ctx) {
-    Future[] futures = Stream.of("tinyint", "smallint", "int", "bigint")
+    List<Future<RowSet<Row>>> futures = Stream.of("tinyint", "smallint", "int", "bigint")
       .flatMap(type -> Stream.of(
         String.format("DROP SEQUENCE IF EXISTS seq_%s", type),
         String.format("CREATE SEQUENCE seq_%s AS %s", type, type)
       ))
       .map(sql -> connection.query(sql).execute())
-      .toArray(Future[]::new);
-    CompositeFuture.all(Arrays.asList(futures)).onComplete(ctx.asyncAssertSuccess(cf -> {
+      .collect(Collectors.toList());
+    CompositeFuture.all(futures).onComplete(ctx.asyncAssertSuccess(cf -> {
       connection
         .query("SELECT * FROM INFORMATION_SCHEMA.SEQUENCES WHERE SEQUENCE_NAME LIKE 'seq_%'")
         .execute()

vertx-mysql-client/src/test/java/io/vertx/mysqlclient/MySQLPoolTest.java

@@ -210,7 +210,7 @@ public void testNoConnectionLeaks(TestContext ctx) {
         .execute(params)
         .onComplete(ctx.asyncAssertSuccess(ids -> {
         CompositeFuture killAll = ids.value().stream()
-          .<Future>map(connId -> conn.query("KILL " + connId).execute())
+          .map(connId -> conn.query("KILL " + connId).execute())
           .collect(Collectors.collectingAndThen(toList(), CompositeFuture::all));
         killAll.compose(cf -> conn.close()).onComplete(ctx.asyncAssertSuccess(v -> killConnections.complete()));
       }));

vertx-pg-client/src/test/java/io/vertx/pgclient/PgBouncerTest.java

@@ -119,7 +119,7 @@ public void testCursor() throws Exception {
     for (int i = 0;i < numConn;i++) {
       connections.add(PgConnection.connect(vertx, new PgConnectOptions(options).setUseLayer7Proxy(true)).toCompletionStage().toCompletableFuture().get(20, TimeUnit.SECONDS));
     }
-    List<Future> list = new ArrayList<>();
+    List<Future<?>> list = new ArrayList<>();
     for (int i = 0;i < numConn;i++) {
       int val = i;
       PgConnection conn = connections.get(i);

vertx-sql-client/src/main/java/io/vertx/sqlclient/impl/ConnectionFactoryBase.java

@@ -48,7 +48,7 @@ protected ConnectionFactoryBase(VertxInternal vertx) {
   }
 
   private void doClose(Promise<Void> p) {
-    List<Future> futures = clients.values().stream().map(client -> client.close()).collect(Collectors.toList());
+    List<Future<Void>> futures = clients.values().stream().map(client -> client.close()).collect(Collectors.toList());
 
     CompositeFuture join = CompositeFuture.join(futures);
 

vertx-sql-client/src/main/java/io/vertx/sqlclient/impl/pool/SqlConnectionPool.java

@@ -242,7 +242,7 @@ public Future<Void> close() {
     Promise<Void> promise = vertx.promise();
     pool.close(ar1 -> {
       if (ar1.succeeded()) {
-        List<Future> results = ar1
+        List<Future<Void>> results = ar1
           .result()
           .stream()
           .map(connection -> connection