Function NewSSEHandler

mcp/sse.go:83–94

NewSSEHandler returns a new [SSEHandler] that creates and manages MCP sessions created via incoming HTTP requests. Sessions are created when the client issues a GET request to the server, which must accept text/event-stream responses (server-sent events). For each such request, a new [SSEServerTran

(getServer func(request *http.Request) *Server, opts *SSEOptions)

// request, or reuse an existing server. If it returns nil, the handler
// will return a 400 Bad Request.
func NewSSEHandler(getServer func(request *http.Request) *Server, opts *SSEOptions) *SSEHandler {
	s := &SSEHandler{
		getServer: getServer,
		sessions:  make(map[string]*SSEServerTransport),
	}

	if opts != nil {
		s.opts = *opts
	}

	return s
}

// A SSEServerTransport is a logical SSE session created through a hanging GET
// request.