increase request timeout for integration tests

Author: tzolov

mcp-spring/mcp-spring-webflux/src/test/java/io/modelcontextprotocol/WebFluxSseIntegrationTests.java

@@ -4,6 +4,8 @@
 
 package io.modelcontextprotocol;
 
+import java.time.Duration;
+
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.springframework.http.server.reactive.HttpHandler;
@@ -39,15 +41,19 @@ class WebFluxSseIntegrationTests extends AbstractMcpClientServerIntegrationTests
 	@Override
 	protected void prepareClients(int port, String mcpEndpoint) {
 
-		clientBuilders.put("httpclient",
-				McpClient.sync(HttpClientSseClientTransport.builder("http://localhost:" + PORT)
-					.sseEndpoint(CUSTOM_SSE_ENDPOINT)
-					.build()));
+		clientBuilders
+			.put("httpclient",
+					McpClient.sync(HttpClientSseClientTransport.builder("http://localhost:" + PORT)
+						.sseEndpoint(CUSTOM_SSE_ENDPOINT)
+						.build()).requestTimeout(Duration.ofHours(10)));
+
 		clientBuilders.put("webflux",
 				McpClient
 					.sync(WebFluxSseClientTransport.builder(WebClient.builder().baseUrl("http://localhost:" + PORT))
 						.sseEndpoint(CUSTOM_SSE_ENDPOINT)
-						.build()));
+						.build())
+					.requestTimeout(Duration.ofHours(10)));
+
 	}
 
 	@Override

mcp-spring/mcp-spring-webflux/src/test/java/io/modelcontextprotocol/WebFluxStreamableIntegrationTests.java

@@ -4,6 +4,8 @@
 
 package io.modelcontextprotocol;
 
+import java.time.Duration;
+
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.springframework.http.server.reactive.HttpHandler;
@@ -37,15 +39,18 @@ class WebFluxStreamableIntegrationTests extends AbstractMcpClientServerIntegrati
 	@Override
 	protected void prepareClients(int port, String mcpEndpoint) {
 
-		clientBuilders.put("httpclient",
-				McpClient.sync(HttpClientStreamableHttpTransport.builder("http://localhost:" + PORT)
-					.endpoint(CUSTOM_MESSAGE_ENDPOINT)
-					.build()));
+		clientBuilders
+			.put("httpclient",
+					McpClient.sync(HttpClientStreamableHttpTransport.builder("http://localhost:" + PORT)
+						.endpoint(CUSTOM_MESSAGE_ENDPOINT)
+						.build()).requestTimeout(Duration.ofHours(10)));
 		clientBuilders.put("webflux",
-				McpClient.sync(WebClientStreamableHttpTransport
-					.builder(WebClient.builder().baseUrl("http://localhost:" + PORT))
-					.endpoint(CUSTOM_MESSAGE_ENDPOINT)
-					.build()));
+				McpClient
+					.sync(WebClientStreamableHttpTransport
+						.builder(WebClient.builder().baseUrl("http://localhost:" + PORT))
+						.endpoint(CUSTOM_MESSAGE_ENDPOINT)
+						.build())
+					.requestTimeout(Duration.ofHours(10)));
 	}
 
 	@Override