class

MCP::Server::StreamableHttpServerTransport

Inherits MCP::Shared::AbstractTransport < MCP::Shared::Transport < Reference < Object

Constants

Log = ::Log.for(self)
MCP_SESSION_ID = "Mcp-Session-Id"
STANDALONE = "standalone"

Constructors

new(stateful : Bool = false, enable_json_response : Bool = false)
Source

Instance methods

close

Closes the connection

Source
handle_delete_request(call : HTTP::Server::Context)
Source
handle_get_request(call : HTTP::Server::Context, session : ServerSSESession)
Source
handle_post_request(call : HTTP::Server::Context)

ameba:disable Metrics/CyclomaticComplexity

Source
send(message : MCP::Protocol::JSONRPCMessage)

ameba:disable Metrics/CyclomaticComplexity

Source
session_id
Source
session_id=(session_id : String | Nil)
Source
start

Starts processing messages, including any connection steps

Source