diff --git a/lib/mcp/server/transports/streamable_http_transport.rb b/lib/mcp/server/transports/streamable_http_transport.rb index 4e01458..c2efc2c 100644 --- a/lib/mcp/server/transports/streamable_http_transport.rb +++ b/lib/mcp/server/transports/streamable_http_transport.rb @@ -150,8 +150,8 @@ def reap_expired_sessions # removed from `@sessions` above, so other threads will not find them # and will not attempt to close the same stream. stream.close - rescue - nil + rescue StandardError + # Ignore close-related errors from already closed/broken streams. end end @@ -239,8 +239,8 @@ def cleanup_session_unsafe(session_id) begin session[:stream]&.close - rescue - nil + rescue StandardError + # Ignore close-related errors from already closed/broken streams. end @sessions.delete(session_id) end