Add request timeout configuration to JettyClientHttpConnector

spring-web/src/main/java/org/springframework/http/client/reactive/JettyClientHttpConnector.java

@@ -17,7 +17,9 @@
 package org.springframework.http.client.reactive;
 
 import java.net.URI;
+import java.time.Duration;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 import java.util.function.Function;
 
 import org.eclipse.jetty.client.HttpClient;
@@ -50,6 +52,8 @@ public class JettyClientHttpConnector implements ClientHttpConnector {
 
 	private ResponseCookie.Parser cookieParser = new JdkResponseCookieParser();
 
+	private long readTimeout;
+
 
 	/**
 	 * Default constructor that creates a new instance of {@link HttpClient}.
@@ -102,6 +106,21 @@ public void setCookieParser(ResponseCookie.Parser parser) {
 		this.cookieParser = parser;
 	}
 
+	/**
+	 * Set the underlying read timeout in milliseconds.
+	 */
+	public void setReadTimeout(long readTimeout) {
+		Assert.isTrue(readTimeout > 0, "Timeout must be a positive value");
+		this.readTimeout = readTimeout;
+	}
+
+	/**
+	 * Set the underlying read timeout as {@code Duration}.
+	 */
+	public void setReadTimeout(Duration readTimeout) {
+		Assert.notNull(readTimeout, "readTimeout is required");
+		this.readTimeout = readTimeout.toMillis();
+	}
 
 	@Override
 	public Mono<ClientHttpResponse> connect(HttpMethod method, URI uri,
@@ -121,6 +140,7 @@ public Mono<ClientHttpResponse> connect(HttpMethod method, URI uri,
 		}
 
 		Request jettyRequest = this.httpClient.newRequest(uri).method(method.toString());
+		jettyRequest.timeout(this.readTimeout, TimeUnit.MILLISECONDS);
 		JettyClientHttpRequest request = new JettyClientHttpRequest(jettyRequest, this.bufferFactory);
 
 		return requestCallback.apply(request).then(execute(request));