We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9770abc commit 9d8c1fbCopy full SHA for 9d8c1fb
crates/rust-mcp-transport/src/stdio.rs
@@ -237,13 +237,11 @@ where
237
238
Ok(stream)
239
} else {
240
- let pending_requests: Arc<Mutex<HashMap<RequestId, tokio::sync::oneshot::Sender<M>>>> =
241
- Arc::new(Mutex::new(HashMap::new()));
242
let (stream, sender, error_stream) = MCPStream::create(
243
Box::pin(tokio::io::stdin()),
244
Mutex::new(Box::pin(tokio::io::stdout())),
245
IoStream::Writable(Box::pin(tokio::io::stderr())),
246
- pending_requests,
+ self.pending_requests.clone(),
247
self.options.timeout,
248
cancellation_token,
249
);
0 commit comments