diff --git a/crates/rmcp/src/transport/async_rw.rs b/crates/rmcp/src/transport/async_rw.rs index 4c4cb4a36..cef4da4c1 100644 --- a/crates/rmcp/src/transport/async_rw.rs +++ b/crates/rmcp/src/transport/async_rw.rs @@ -298,9 +298,13 @@ impl Decoder for JsonRpcMessageCodec { let line = without_carriage_return(line); // Use compatibility handling function - let item = match try_parse_with_compatibility(line, "decode")? { - Some(item) => item, - None => return Ok(None), // Skip non-standard message + let item = match try_parse_with_compatibility(line, "decode") { + Ok(Some(item)) => item, + Ok(None) => return Ok(None), // Skip non-standard message + Err(e) => { + // Ignore lines that do not parse + continue; + }, }; return Ok(Some(item)); }