We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents dab6a4b + 1ddd26b commit 52f8384Copy full SHA for 52f8384
1 file changed
lib/mcp/server/transports/streamable_http_transport.rb
@@ -269,12 +269,12 @@ def reap_expired_sessions
269
def send_to_stream(stream, data)
270
message = data.is_a?(String) ? data : data.to_json
271
stream.write("data: #{message}\n\n")
272
- stream.flush if stream.respond_to?(:flush)
+ stream.flush
273
end
274
275
def send_ping_to_stream(stream)
276
stream.write(": ping #{Time.now.iso8601}\n\n")
277
278
279
280
def handle_post(request)
0 commit comments