@@ -77,12 +77,14 @@ public class JdkHttpClient implements HttpClient {
77
77
private final List <WebSocket > websockets ;
78
78
private final ExecutorService executorService ;
79
79
private final Duration readTimeout ;
80
+ private final Duration connectTimeout ;
80
81
81
82
JdkHttpClient (ClientConfig config ) {
82
83
Objects .requireNonNull (config , "Client config must be set" );
83
84
84
85
this .messages = new JdkHttpMessages (config );
85
86
this .readTimeout = config .readTimeout ();
87
+ this .connectTimeout = config .connectionTimeout ();
86
88
this .websockets = new ArrayList <>();
87
89
this .handler = config .filter ().andFinally (this ::execute0 );
88
90
@@ -98,7 +100,7 @@ public class JdkHttpClient implements HttpClient {
98
100
99
101
java .net .http .HttpClient .Builder builder =
100
102
java .net .http .HttpClient .newBuilder ()
101
- .connectTimeout (config . connectionTimeout () )
103
+ .connectTimeout (connectTimeout )
102
104
.followRedirects (java .net .http .HttpClient .Redirect .NEVER )
103
105
.executor (executorService );
104
106
@@ -165,6 +167,7 @@ public WebSocket openSocket(HttpRequest request, WebSocket.Listener listener) {
165
167
CompletableFuture <java .net .http .WebSocket > webSocketCompletableFuture =
166
168
client
167
169
.newWebSocketBuilder ()
170
+ .connectTimeout (connectTimeout )
168
171
.buildAsync (
169
172
uri ,
170
173
new java .net .http .WebSocket .Listener () {
0 commit comments