Skip to content

Commit 1a673b3

Browse files
committed
refactor: improve MCP client timeout handling and reactive testing
- Add configurable initialization timeout separate from request timeout - Rename ServletSse* test classes to HttpSse* for better naming consistency - Replace direct .block() calls with StepVerifier for better reactive testing - Change ping() method to return Mono instead of Mono - Improve error handling and reactive programming patterns throughout tests - Chain reactive operations for cleaner test flow Signed-off-by: Christian Tzolov <[email protected]>
1 parent 6ef1b58 commit 1a673b3

File tree

12 files changed

+339
-294
lines changed

12 files changed

+339
-294
lines changed

Diff for: mcp-spring/mcp-spring-webflux/src/test/java/io/modelcontextprotocol/client/WebFluxSseMcpAsyncClientTests.java

-7
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,6 @@
44

55
package io.modelcontextprotocol.client;
66

7-
import java.time.Duration;
8-
97
import io.modelcontextprotocol.client.transport.WebFluxSseClientTransport;
108
import io.modelcontextprotocol.spec.ClientMcpTransport;
119
import org.junit.jupiter.api.Timeout;
@@ -48,9 +46,4 @@ public void onClose() {
4846
container.stop();
4947
}
5048

51-
@Override
52-
protected Duration getTimeoutDuration() {
53-
return Duration.ofMillis(300);
54-
}
55-
5649
}

Diff for: mcp-spring/mcp-spring-webflux/src/test/java/io/modelcontextprotocol/client/WebFluxSseMcpSyncClientTests.java

-7
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,6 @@
44

55
package io.modelcontextprotocol.client;
66

7-
import java.time.Duration;
8-
97
import io.modelcontextprotocol.client.transport.WebFluxSseClientTransport;
108
import io.modelcontextprotocol.spec.ClientMcpTransport;
119
import org.junit.jupiter.api.Timeout;
@@ -48,9 +46,4 @@ protected void onClose() {
4846
container.stop();
4947
}
5048

51-
@Override
52-
protected Duration getTimeoutDuration() {
53-
return Duration.ofMillis(300);
54-
}
55-
5649
}

0 commit comments

Comments
 (0)