@@ -137,7 +137,7 @@ public void testV2Client() throws InterruptedException, ExecutionException, Time
137
137
138
138
assertEquals ("message" , receivedMessage .get ());
139
139
subResp .getHandler ().closeStream ().get ();
140
- subscriptionClosed .get (1 , TimeUnit .SECONDS );
140
+ subscriptionClosed .get (5 , TimeUnit .SECONDS );
141
141
142
142
subscriptionClosed = new CompletableFuture <>();
143
143
receivedMessage = new CompletableFuture <>();
@@ -165,7 +165,7 @@ public void onStreamClosed() {
165
165
166
166
assertEquals ("message" , receivedMessage .get ());
167
167
subResp .getHandler ().closeStream ().get ();
168
- subscriptionClosed .get (1 , TimeUnit .SECONDS );
168
+ subscriptionClosed .get (5 , TimeUnit .SECONDS );
169
169
170
170
subscriptionClosed = new CompletableFuture <>();
171
171
receivedMessage = new CompletableFuture <>();
@@ -194,7 +194,7 @@ public void onStreamClosed() {
194
194
195
195
assertEquals ("message" , receivedMessage .get ());
196
196
subRespAsync .getHandler ().closeStream ().get ();
197
- subscriptionClosed .get (1 , TimeUnit .SECONDS );
197
+ subscriptionClosed .get (5 , TimeUnit .SECONDS );
198
198
199
199
subscriptionClosed = new CompletableFuture <>();
200
200
receivedMessage = new CompletableFuture <>();
@@ -209,6 +209,6 @@ public void onStreamClosed() {
209
209
210
210
assertEquals ("message" , receivedMessage .get ());
211
211
subRespAsync .getHandler ().closeStream ().get ();
212
- subscriptionClosed .get (1 , TimeUnit .SECONDS );
212
+ subscriptionClosed .get (5 , TimeUnit .SECONDS );
213
213
}
214
214
}
0 commit comments