@@ -52,8 +52,8 @@ private static AsyncHttpClient createClient() {
52
52
AsyncHttpClientConfig config = new DefaultAsyncHttpClientConfig .Builder ()
53
53
.setEnableAutomaticDecompression (true )
54
54
.setCompressionEnforced (true )
55
- .setReadTimeout (Duration .ofMinutes (8 ))
56
- .setRequestTimeout (Duration .ofMinutes (8 ))
55
+ .setReadTimeout (Duration .ofMinutes (15 ))
56
+ .setRequestTimeout (Duration .ofMinutes (15 ))
57
57
.setConnectTimeout (Duration .ofSeconds (1 ))
58
58
.build ();
59
59
return new DefaultAsyncHttpClient (config );
@@ -90,7 +90,7 @@ static void stopServer() {
90
90
}
91
91
92
92
@ Test
93
- @ Timeout (value = 8 , unit = TimeUnit .MINUTES )
93
+ @ Timeout (value = 15 , unit = TimeUnit .MINUTES )
94
94
void handleLargeResponse () throws Throwable {
95
95
AtomicInteger status = new AtomicInteger (-1 );
96
96
AtomicLong bytesReceived = new AtomicLong ();
@@ -135,7 +135,7 @@ public void onThrowable(Throwable t) {
135
135
}
136
136
});
137
137
138
- future .get (8 , TimeUnit .MINUTES );
138
+ future .get (15 , TimeUnit .MINUTES );
139
139
140
140
assertEquals (200 , status .get ());
141
141
assertEquals (0 , throwableCount .get ());
0 commit comments