@@ -137,7 +137,7 @@ public void testV2Client() throws InterruptedException, ExecutionException, Time
137137
138138 assertEquals ("message" , receivedMessage .get ());
139139 subResp .getHandler ().closeStream ().get ();
140- subscriptionClosed .get (1 , TimeUnit .SECONDS );
140+ subscriptionClosed .get (5 , TimeUnit .SECONDS );
141141
142142 subscriptionClosed = new CompletableFuture <>();
143143 receivedMessage = new CompletableFuture <>();
@@ -165,7 +165,7 @@ public void onStreamClosed() {
165165
166166 assertEquals ("message" , receivedMessage .get ());
167167 subResp .getHandler ().closeStream ().get ();
168- subscriptionClosed .get (1 , TimeUnit .SECONDS );
168+ subscriptionClosed .get (5 , TimeUnit .SECONDS );
169169
170170 subscriptionClosed = new CompletableFuture <>();
171171 receivedMessage = new CompletableFuture <>();
@@ -194,7 +194,7 @@ public void onStreamClosed() {
194194
195195 assertEquals ("message" , receivedMessage .get ());
196196 subRespAsync .getHandler ().closeStream ().get ();
197- subscriptionClosed .get (1 , TimeUnit .SECONDS );
197+ subscriptionClosed .get (5 , TimeUnit .SECONDS );
198198
199199 subscriptionClosed = new CompletableFuture <>();
200200 receivedMessage = new CompletableFuture <>();
@@ -209,6 +209,6 @@ public void onStreamClosed() {
209209
210210 assertEquals ("message" , receivedMessage .get ());
211211 subRespAsync .getHandler ().closeStream ().get ();
212- subscriptionClosed .get (1 , TimeUnit .SECONDS );
212+ subscriptionClosed .get (5 , TimeUnit .SECONDS );
213213 }
214214}
0 commit comments