File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
vertx-pg-client/src/test/java/io/vertx/pgclient Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -69,6 +69,7 @@ public void testCloseAutomatically(TestContext ctx) {
69
69
int instances = maxSize * 4 ;
70
70
Async latch = ctx .async (instances );
71
71
AtomicReference <String > deployment = new AtomicReference <>();
72
+ Async async = ctx .async ();
72
73
vertx .deployVerticle (() -> new AbstractVerticle () {
73
74
@ Override
74
75
public void start () {
@@ -82,7 +83,7 @@ public void start() {
82
83
vertx .undeploy (deployment .get ())
83
84
.compose (v -> PgConnection .connect (vertx , options ))
84
85
.compose (conn -> waitUntilConnCountIs (conn , 10 , 1 )
85
- ).onComplete (ctx .asyncAssertSuccess ());
86
+ ).onComplete (ctx .asyncAssertSuccess (v -> async . complete () ));
86
87
}
87
88
88
89
private Future <Void > waitUntilConnCountIs (SqlConnection conn , int remaining , int expectedCount ) {
You can’t perform that action at this time.
0 commit comments