modelcontextprotocol/rust-sdk
Watch
1
0
Fork
You've already forked rust-sdk
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 2

chore: clean up optional dependencies (#546)

Browse source
This commit is contained in:
Jack Amadeo 2026-01-13 21:29:35 -05:00 • committed by GitHub
commit 46e149ee8b
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
3 changed files with 10 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

4
crates/rmcp/Cargo.toml
View file

@ -25,7 +25,7 @@ tokio-util = { version = "0.7" }
pin-project-lite = "0.2" pin-project-lite = "0.2"
pastey = { version = "0.2.0", optional = true } pastey = { version = "0.2.0", optional = true }
# oauth2 support # oauth2 support
oauth2 = { version = "5.0", optional = true } oauth2 = { version = "5.0", optional = true, default-features = false, features = ["reqwest"] }
# for auto generate schema # for auto generate schema
schemars = { version = "1.0", optional = true, features = ["chrono04"] } schemars = { version = "1.0", optional = true, features = ["chrono04"] }
@ -108,7 +108,7 @@ client-side-sse = ["dep:sse-stream", "dep:http"]
# Streamable HTTP client # Streamable HTTP client
transport-streamable-http-client = ["client-side-sse", "transport-worker"] transport-streamable-http-client = ["client-side-sse", "transport-worker"]
transport-streamable-http-client-reqwest = ["transport-streamable-http-client", "reqwest"] transport-streamable-http-client-reqwest = ["transport-streamable-http-client", "__reqwest"]
transport-async-rw = ["tokio/io-util", "tokio-util/codec"] transport-async-rw = ["tokio/io-util", "tokio-util/codec"]
transport-io = ["transport-async-rw", "tokio/io-std"] transport-io = ["transport-async-rw", "tokio/io-std"]

7
crates/rmcp/src/transport/streamable_http_client.rs
View file

@ -335,7 +335,12 @@ impl<C: StreamableHttpClient> Worker for StreamableHttpClientWorker<C> {
}; };
// Store session info for cleanup when run() exits (not spawned, so cleanup completes before close() returns) // Store session info for cleanup when run() exits (not spawned, so cleanup completes before close() returns)
let session_cleanup_info = session_id.as_ref().map(|sid| { let session_cleanup_info = session_id.as_ref().map(|sid| {
(self.client.clone(), config.uri.clone(), sid.clone(), config.auth_header.clone()) (
self.client.clone(),
config.uri.clone(),
sid.clone(),
config.auth_header.clone(),
)
}); });
context.send_to_handler(message).await?; context.send_to_handler(message).await?;

2
crates/rmcp/tests/test_close_connection.rs
View file

@ -4,7 +4,7 @@ mod common;
use std::time::Duration; use std::time::Duration;
use common::handlers::{TestClientHandler, TestServer}; use common::handlers::{TestClientHandler, TestServer};
use rmcp::{service::QuitReason, ServiceExt}; use rmcp::{ServiceExt, service::QuitReason};
/// Test that close() properly shuts down the connection /// Test that close() properly shuts down the connection
#[tokio::test] #[tokio::test]