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

fix(Transport): close oneshot transport on error (#340)

Browse source
This commit is contained in:
Pedro DiazVargas 2025-07-29 23:03:21 -04:00 • committed by GitHub
commit 855f57e0e7
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
crates/rmcp/src/transport.rs
View file

@ -221,7 +221,8 @@ where
item: TxJsonRpcMessage<R>, item: TxJsonRpcMessage<R>,
) -> impl Future<Output = Result<(), Self::Error>> + Send + 'static { ) -> impl Future<Output = Result<(), Self::Error>> + Send + 'static {
let sender = self.sender.clone(); let sender = self.sender.clone();
let terminate = matches!(item, TxJsonRpcMessage::<R>::Response(_)); let terminate = matches!(item, TxJsonRpcMessage::<R>::Response(_))
|| matches!(item, TxJsonRpcMessage::<R>::Error(_));
let signal = self.finished_signal.clone(); let signal = self.finished_signal.clone();
async move { async move {
sender.send(item).await?; sender.send(item).await?;