Function NewStreamableHTTPHandler

mcp/streamable.go:194–210

NewStreamableHTTPHandler returns a new [StreamableHTTPHandler]. The getServer function is used to create or look up servers for new sessions. It is OK for getServer to return the same server multiple times. If getServer returns nil, a 400 Bad Request will be served.

(getServer func(*http.Request) *Server, opts *StreamableHTTPOptions)

// sessions. It is OK for getServer to return the same server multiple times.
// If getServer returns nil, a 400 Bad Request will be served.
func NewStreamableHTTPHandler(getServer func(*http.Request) *Server, opts *StreamableHTTPOptions) *StreamableHTTPHandler {
	h := &StreamableHTTPHandler{
		getServer: getServer,
		sessions:  make(map[string]*sessionInfo),
	}
	if opts != nil {
		h.opts = *opts
	}

	h.opts.Logger = ensureLogger(h.opts.Logger)

	if h.opts.CrossOriginProtection == nil && enableoriginverification == "1" {
		h.opts.CrossOriginProtection = &http.CrossOriginProtection{}
	}

	return h
}

// closeAll closes all ongoing sessions, for tests.
//