Adapt to Future#eventually change

vert-x3 · Aug 31, 2023 · d55c915 · d55c915
1 parent a3571b4
commit d55c915
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/src/main/java/io/vertx/redis/client/impl/BaseRedisClient.java b/src/main/java/io/vertx/redis/client/impl/BaseRedisClient.java
@@ -43,7 +43,7 @@ public void close() {
       .compose(conn ->
         conn.send(request)
           // regardless of the result, return the connection to the pool
-          .eventually(e ->
+          .eventually(() ->
             conn.close()
               .onFailure(LOG::warn)));
   }
@@ -66,7 +66,7 @@ public void close() {
         .compose(conn ->
           conn.batch(requests)
             // regardless of the result, return the connection to the pool
-            .eventually(e ->
+            .eventually(() ->
               conn.close().onFailure(LOG::warn)));
     }
   }

diff --git a/src/main/java/io/vertx/redis/client/impl/RedisSentinelClient.java b/src/main/java/io/vertx/redis/client/impl/RedisSentinelClient.java
@@ -210,7 +210,7 @@ private void isSentinelOk(String endpoint, RedisConnectOptions argument, Handler
           .send(cmd(PING))
           .onFailure(err -> handler.handle(Future.failedFuture(err)))
           .onSuccess(ok -> handler.handle(Future.succeededFuture(uri)))
-          .eventually(v -> conn.close().onFailure(LOG::warn));
+          .eventually(() -> conn.close().onFailure(LOG::warn));
       });
   }
 
@@ -235,7 +235,7 @@ private void getMasterFromEndpoint(String endpoint, RedisSentinelConnectOptions
               handler.handle(Future.succeededFuture(new RedisURI(uri, rHost.contains(":") ? "[" + rHost + "]" : rHost, rPort)));
             }
           })
-          .eventually(v -> conn.close().onFailure(LOG::warn));
+          .eventually(() -> conn.close().onFailure(LOG::warn));
       });
   }
 
@@ -281,7 +281,7 @@ private void getReplicaFromEndpoint(String endpoint, RedisSentinelConnectOptions
               }
             }
           })
-          .eventually(v -> conn.close().onFailure(LOG::warn));
+          .eventually(() -> conn.close().onFailure(LOG::warn));
       });
   }