diff --git a/vertx-pg-client/src/test/java/io/vertx/tests/pgclient/PgConnectionTest.java b/vertx-pg-client/src/test/java/io/vertx/tests/pgclient/PgConnectionTest.java index f57a63bd1..91711ebb0 100644 --- a/vertx-pg-client/src/test/java/io/vertx/tests/pgclient/PgConnectionTest.java +++ b/vertx-pg-client/src/test/java/io/vertx/tests/pgclient/PgConnectionTest.java @@ -120,9 +120,9 @@ public void testCancelRequest(TestContext ctx) { ctx.assertTrue(hasSqlstateCode(error, ERRCODE_QUERY_CANCELED), error.getMessage()); async.countDown(); })); - ((PgConnection)conn) + vertx.setTimer(1000, id -> ((PgConnection)conn) .cancelRequest() - .onComplete(ctx.asyncAssertSuccess()); + .onComplete(ctx.asyncAssertSuccess())); conn.closeHandler(v -> { ctx.assertEquals(1, async.count());