From 855f57e0e79a8237cb60419a0a7567eebae9c8ef Mon Sep 17 00:00:00 2001 From: Pedro DiazVargas Date: Tue, 29 Jul 2025 23:03:21 -0400 Subject: [PATCH] fix(Transport): close oneshot transport on error (#340) --- crates/rmcp/src/transport.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/crates/rmcp/src/transport.rs b/crates/rmcp/src/transport.rs index 4cc8476..81286fe 100644 --- a/crates/rmcp/src/transport.rs +++ b/crates/rmcp/src/transport.rs @@ -221,7 +221,8 @@ where item: TxJsonRpcMessage, ) -> impl Future> + Send + 'static { let sender = self.sender.clone(); - let terminate = matches!(item, TxJsonRpcMessage::::Response(_)); + let terminate = matches!(item, TxJsonRpcMessage::::Response(_)) + || matches!(item, TxJsonRpcMessage::::Error(_)); let signal = self.finished_signal.clone(); async move { sender.send(item).await?;