Skip to content

Commit 51e6760

Browse files
committed
Fix expected type of pg_terminate_backend result in testNoConnectionLeaks
1 parent ddec7ad commit 51e6760

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -507,9 +507,9 @@ public void testPoolConnectTimeout(TestContext ctx) {
507507
public void testNoConnectionLeaks(TestContext ctx) {
508508
Async killConnections = ctx.async();
509509
PgConnection.connect(vertx, options).onComplete(ctx.asyncAssertSuccess(conn -> {
510-
Collector<Row, ?, List<Integer>> collector = mapping(row -> row.getInteger(0), toList());
510+
Collector<Row, ?, List<Boolean>> collector = mapping(row -> row.getBoolean(0), toList());
511511
String sql = "SELECT pg_terminate_backend(pid) FROM pg_stat_activity WHERE pid <> pg_backend_pid() AND datname = $1";
512-
PreparedQuery<SqlResult<List<Integer>>> preparedQuery = conn.preparedQuery(sql).collecting(collector);
512+
PreparedQuery<SqlResult<List<Boolean>>> preparedQuery = conn.preparedQuery(sql).collecting(collector);
513513
Tuple params = Tuple.of(options.getDatabase());
514514
preparedQuery.execute(params).compose(cf -> conn.close()).onComplete(ctx.asyncAssertSuccess(v -> killConnections.complete()));
515515
}));

0 commit comments

Comments
 (0)