Skip to content

Commit 119ebf9

Browse files
author
wenhaozhao
committed
feat: McpSession/McpAsyncSession implements AutoCloseable
1 parent dde0125 commit 119ebf9

File tree

2 files changed

+12
-2
lines changed

2 files changed

+12
-2
lines changed

core/src/main/java/com/google/adk/tools/mcp/McpAsyncSession.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
import io.modelcontextprotocol.client.McpAsyncClient;
44
import io.modelcontextprotocol.spec.McpSchema;
55

6-
public class McpAsyncSession {
6+
public class McpAsyncSession implements AutoCloseable {
77
private final McpAsyncClient client;
88
private final McpSchema.InitializeResult initResult;
99

@@ -19,4 +19,9 @@ public McpAsyncClient client() {
1919
public McpSchema.InitializeResult initResult() {
2020
return this.initResult;
2121
}
22+
23+
@Override
24+
public void close() throws Exception {
25+
this.client.close();
26+
}
2227
}

core/src/main/java/com/google/adk/tools/mcp/McpSession.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
import io.modelcontextprotocol.client.McpSyncClient;
44
import io.modelcontextprotocol.spec.McpSchema;
55

6-
public class McpSession {
6+
public class McpSession implements AutoCloseable {
77

88
private final McpSyncClient client;
99
private final McpSchema.InitializeResult initResult;
@@ -20,4 +20,9 @@ public McpSyncClient client() {
2020
public McpSchema.InitializeResult initResult() {
2121
return this.initResult;
2222
}
23+
24+
@Override
25+
public void close() throws Exception {
26+
this.client.close();
27+
}
2328
}

0 commit comments

Comments
 (0)