Skip to content

Commit d55c915

Browse files
committed
Adapt to Future#eventually change
1 parent a3571b4 commit d55c915

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

src/main/java/io/vertx/redis/client/impl/BaseRedisClient.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ public void close() {
4343
.compose(conn ->
4444
conn.send(request)
4545
// regardless of the result, return the connection to the pool
46-
.eventually(e ->
46+
.eventually(() ->
4747
conn.close()
4848
.onFailure(LOG::warn)));
4949
}
@@ -66,7 +66,7 @@ public void close() {
6666
.compose(conn ->
6767
conn.batch(requests)
6868
// regardless of the result, return the connection to the pool
69-
.eventually(e ->
69+
.eventually(() ->
7070
conn.close().onFailure(LOG::warn)));
7171
}
7272
}

src/main/java/io/vertx/redis/client/impl/RedisSentinelClient.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -210,7 +210,7 @@ private void isSentinelOk(String endpoint, RedisConnectOptions argument, Handler
210210
.send(cmd(PING))
211211
.onFailure(err -> handler.handle(Future.failedFuture(err)))
212212
.onSuccess(ok -> handler.handle(Future.succeededFuture(uri)))
213-
.eventually(v -> conn.close().onFailure(LOG::warn));
213+
.eventually(() -> conn.close().onFailure(LOG::warn));
214214
});
215215
}
216216

@@ -235,7 +235,7 @@ private void getMasterFromEndpoint(String endpoint, RedisSentinelConnectOptions
235235
handler.handle(Future.succeededFuture(new RedisURI(uri, rHost.contains(":") ? "[" + rHost + "]" : rHost, rPort)));
236236
}
237237
})
238-
.eventually(v -> conn.close().onFailure(LOG::warn));
238+
.eventually(() -> conn.close().onFailure(LOG::warn));
239239
});
240240
}
241241

@@ -281,7 +281,7 @@ private void getReplicaFromEndpoint(String endpoint, RedisSentinelConnectOptions
281281
}
282282
}
283283
})
284-
.eventually(v -> conn.close().onFailure(LOG::warn));
284+
.eventually(() -> conn.close().onFailure(LOG::warn));
285285
});
286286
}
287287

0 commit comments

Comments
 (0)